Function actix_web::actix::dev::channel::channel

pub fn channel<A>(buffer: usize) -> (AddressSender<A>, AddressReceiver<A>) where
    A: Actor, 

Creates an in-memory channel implementation of the Stream trait with bounded capacity.

This method creates a concrete implementation of the Stream trait which can be used to send values across threads in a streaming fashion. This channel is unique in that it implements back pressure to ensure that the sender never outpaces the receiver. The channel capacity is equal to buffer + num-senders. In other words, each sender gets a guaranteed slot in the channel capacity, and on top of that there are buffer "first come, first serve" slots available to all senders.

The Receiver returned implements the Stream trait and has access to any number of the associated combinators for transforming the result.