code: public void initiateOnReceivingSide(Socket socket, boolean isForOutgoing, int version) throws IOException
      {
          if (isForOutgoing)
              outgoing.start(socket, version);
          else
              incoming.start(socket, version);
      }
docs: Set up outgoing message handler on receiving side.
  
  @param socket socket to use for {@link org.apache.cassandra.streaming.ConnectionHandler.OutgoingMessageHandler}.
  @param version Streaming message version
  @throws IOException