public function emit(Message $message, $messageCode)
    {
        $payload = $this->encodeMessage($message, $messageCode);
        $stream  = $this->connection->createStream();

        return $this->connection->send($payload, $stream);
    }
public function emit(Message $message, $messageCode)
    {
        $payload = $this->encodeMessage($message, $messageCode);
        $stream  = $this->connection->createStream();

        return $this->connection->send($payload, $stream);
    }
public function emit ( Message $ message , $ messageCode ) { $ payload = $ this -> encodeMessage ( $ message , $ messageCode ) ; $ stream = $ this -> connection -> createStream ( ) ; return $ this -> connection -> send ( $ payload , $ stream ) ; }
Send a Protobuf message using a new stream and return it for future usage

@param \DrSlump\Protobuf\Message $message
@param integer                   $messageCode

@return \Riak\Client\Core\Transport\Proto\ProtoStream
Send a Protobuf message using a new stream and return it for future usage