code: public void initiate() throws IOException
      {
          logger.debug("[Stream #{}] Sending stream init for incoming stream", session.planId());
          Socket incomingSocket = session.createConnection();
          incoming.start(incomingSocket, StreamMessage.CURRENT_VERSION);
          incoming.sendInitMessage(incomingSocket, true);
  
          logger.debug("[Stream #{}] Sending stream init for outgoing stream", session.planId());
          Socket outgoingSocket = session.createConnection();
          outgoing.start(outgoingSocket, StreamMessage.CURRENT_VERSION);
          outgoing.sendInitMessage(outgoingSocket, false);
      }
docs: Set up incoming message handler and initiate streaming.
  
  This method is called once on initiator.
  
  @throws IOException