Struct FnStreamingHandler 

pub struct FnStreamingHandler<F> { /* private fields */ }

Wrapper that implements StreamingHandler for async functions.

Implementations

impl<F> FnStreamingHandler<F>

pub fn new(f: F) -> Self

Create a new function streaming handler.

Trait Implementations

impl<F, Fut, Req, Res, B> StreamingHandler<Req, Res> for FnStreamingHandler<F>

where F: Fn(RequestContext, Req) -> Fut + Send + Sync + 'static, Fut: Future<Output = ServiceResult<ServiceStream<B>>> + Send + 'static, Req: Message + Send + 'static, Res: Message + Send + 'static, B: Encodable<Res> + Send + 'static,

type Item = B

The stream item type. Typically Res itself; may be PreEncoded or MaybeBorrowed for handlers that encode borrowing views per item.

fn call( &self, ctx: RequestContext, request: Req, ) -> BoxFuture<'static, ServiceResult<ServiceStream<B>>>

Handle a server streaming RPC request.