fn send<Item, S>(
    &self,
    ctx: &grpcio::RpcContext<'_>,
    sink: grpcio::ServerStreamingSink<Item>,
    stream: S,
  ) where
    Item: Send + 'static,
    S: Stream<Item = (Item, grpcio::WriteFlags), Error = grpcio::Error> + Send + 'static,
  {
    ctx.spawn(stream.forward(sink).map(|_| ()).map_err(|_| ()));
  }
///
/// Sends a stream of responses down a sink, in ctx's threadpool.
///
Sends a stream of responses down a sink, in ctx's threadpool.
Sends a stream of responses down a sink in ctx ' s threadpool .
fn send<Item, S>(
    &self,
    ctx: &grpcio::RpcContext<'_>,
    sink: grpcio::ServerStreamingSink<Item>,
    stream: S,
  ) where
    Item: Send + 'static,
    S: Stream<Item = (Item, grpcio::WriteFlags), Error = grpcio::Error> + Send + 'static,
  {
    ctx.spawn(stream.forward(sink).map(|_| ()).map_err(|_| ()));
  }
fn send < Item , S > ( & self , ctx : & grpcio :: RpcContext < ' _ > , sink : grpcio :: ServerStreamingSink < Item > , stream : S , ) where Item : Send + ' static , S : Stream < Item = ( Item , grpcio :: WriteFlags ) , Error = grpcio :: Error > + Send + ' static , { ctx . spawn ( stream . forward ( sink ) . map ( | _ | ( ) ) . map_err ( | _ | ( ) ) ) ; }
Sends a stream of responses down a sink, in ctx's threadpool.
Sends a stream of responses down a sink in ctx ' s threadpool .
&self
ctx
&grpcio::RpcContext<'_>
sink
grpcio::ServerStreamingSink<Item>
stream
S