Function tokio_stdout::spawn_encoder_sink_unbounded [] [src]

pub fn spawn_encoder_sink_unbounded<I, E, N>(encoder: N) -> UnboundedSender<I> where
    I: Send + 'static,
    E: From<Error> + Debug + 'static,
    N: Encoder<Item = I, Error = E> + Send + 'static, 

Spawn a new thread that encodes each item and writes it to stdout. The channel to send items to the spawned thread is unbounded in size.