Struct ServerRpc 

pub struct ServerRpc { /* private fields */ }

Server-side RPC state machine.

Implementations

impl ServerRpc

pub fn from_call_start( ctx: Context, call_start: CallStart, writer: Arc<dyn PacketWriter>, ) -> Self

Creates a new ServerRpc from a CallStart packet.

pub fn context(&self) -> &Context

Returns the context for this RPC.

pub fn service(&self) -> &str

Returns the service ID.

pub fn method(&self) -> &str

Returns the method ID.

pub async fn wait(&self) -> Result<()>

Waits for the RPC to finish.

pub async fn handle_packet(&self, packet: Packet) -> Result<()>

Handles an incoming packet.

pub async fn handle_stream_close(&self, err: Option<String>) -> Result<()>

Handles stream close from the transport.

pub async fn send_error(&self, error: String) -> Result<()>

Sends an error response and closes.

Trait Implementations

impl Stream for ServerRpc

fn context(&self) -> &Context

Returns the context for this stream.

fn send_bytes<'life0, 'async_trait>( &'life0 self, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends raw bytes on the stream.

fn recv_bytes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receives raw bytes from the stream.

fn close_send<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the send side of the stream.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes both sides of the stream.