synchronized reading and writing

[Chad Pettit]

Using TCPSession how does synchronized reading and writing work.

I have something like this:

void Connection::runTransmitter()
{
   char line[200];
   std::iostream *connection = tcp();
   connection->write(_message.c_str(), _message.length());

   if (isPending(Socket::pendingInput))
       *connection >> line;  
   std::cerr << "Transmit: " << line << std::endl;
}

void Connection::runReceiver()
{   
   char line[200];
   std::iostream* connection = tcp();

   if (isPending(Socket::pendingInput))
       *connection >> line;
  
   std::cerr << "Receive: " << line << std::endl;
   *connection << "message successfully received";   
}

It hangs at the isPending function on the Receiver side.  If I put in a 
endStream() call on the transmitter side, the receiver gets the message, 
but the tranmitter then hangs on its isPending.  The endStream function 
ends the socket as well as the stream.  I don't believe this is correct 
because I eventually want the communication to be ongoing between the 
receiver and transmitter.

Any help would be greatly appreciated.