Struct RpcStream 

pub struct RpcStream<T> { /* private fields */ }

A bidirectional RPC stream.

RpcStream allows sending and receiving multiple items over a single RPC call. It implements Stream for receiving items.

Example

// Server streaming
async fn get_logs(&self, filter: Filter) -> RpcStream<LogEntry>;

// Client usage
let mut stream = client.get_logs(filter).await?;
while let Some(entry) = stream.next().await {
    println!("{:?}", entry?);
}

Implementations

impl<T> RpcStream<T>

pub fn new(rx: Receiver<Result<T, String>>) -> Self

Create a new stream with the given receiver.

pub fn bidirectional(rx: Receiver<Result<T, String>>, tx: Sender<Bytes>) -> Self

Create a bidirectional stream with both send and receive capabilities.

pub fn sender(&self) -> Option<&StreamSender<T>>

Get the sender half for bidirectional streams.

pub async fn next(&mut self) -> Option<Result<T, String>>

Receive the next item from the stream.

Trait Implementations

impl<T: Serialize + Unpin> ErasedStream for RpcStream<T>

fn poll_next_bytes( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Vec<u8>, String>>>

Get the next item as serialized bytes.

impl<T: Unpin> Stream for RpcStream<T>

type Item = Result<T, String>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.