public void testBasic() throws Exception {
		client1.bind(loopBackAnyPort);		
		InetSocketAddress remoteAddr = new InetSocketAddress(loopBack, srvrChannel.getLocalAddress().getPort());
		FutureOperation future = client1.connect(remoteAddr);
		future.setListener((OperationCallback) clientConnect);
		clientConnect.expect("finished");
		
		client1.registerForReads((DataListener)clientHandler);
		
		future.waitForOperation(); //should return immediately since listener fired
		
		serverHandler = MockObjectFactory.createMock(DataListener.class);
		CalledMethod m = serverAccept.expect("connected");
		serverTcpChannel = (Channel)m.getAllParams()[0];
		serverTcpChannel.registerForReads((DataListener) serverHandler);
		
		boolean isConnected = client1.isConnected();
		assertTrue("Client should be connected", isConnected);
		
		verifyDataPassing();
		verifyTearDown();	
	}