Struct RpcStreamingObserver 

pub struct RpcStreamingObserver { /* private fields */ }

Lightweight observer for streaming RPC adapters.

Implementations

impl RpcStreamingObserver

pub fn new( service: impl Into<String>, method: impl Into<String>, config: RpcStreamingConfig, ) -> Self

Creates an observer for one stream.

pub async fn record_send(&self)

Records a send event.

pub async fn record_recv(&self)

Records a receive event.

pub async fn finish<T>(&self, result: Result<T, Status>)

Finishes the stream with a final result.

pub async fn snapshot(&self) -> RpcStreamingSnapshot

Returns a snapshot.

Trait Implementations

impl Clone for RpcStreamingObserver

fn clone(&self) -> RpcStreamingObserver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RpcStreamingObserver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.