// actually send the message accross the wire
//
actually send the message accross the wire
actually send the message accross the wire
async fn send_msg( &mut self, msg: Wf ) -> Result<(), PeerErr>
	{
		trace!( "{}: sending OUT WireFormat", self.identify() );
		match &mut self.outgoing
		{
			Some( out ) =>
			{
				let sid = msg.sid();
				let cid = msg.cid();
				out.send( msg ).await
					.map_err( |source|
					{
						let ctx = self.ctx( sid, cid, "Sending out WireFormat" );
						PeerErr::WireFormat{ ctx, source }
					})
			}
			None =>
			{
				let ctx = PeerErrCtx::default().context( "register_relayed_services".to_string() );
				Err( PeerErr::ConnectionClosed{ ctx } )
			}
		}
	}
async fn send_msg ( & mut self , msg : Wf ) -> Result < ( ) , PeerErr > { trace ! ( " " self identify ( ) ) ; match & mut self . outgoing { Some ( out ) => { let sid = msg . sid ( ) ; let cid = msg . cid ( ) ; out . send ( msg ) . await . map_err ( | source | { let ctx = self . ctx ( sid , cid , " " ) ; PeerErr :: WireFormat { ctx , source } } ) } None => { let ctx = PeerErrCtx :: default ( ) . context ( " " . to_string ( ) ) ; Err ( PeerErr :: ConnectionClosed { ctx } ) } } }
actually send the message accross the wire
actually send the message accross the wire
&mut self
msg
Wf