Function atm_async_utils::test_channel::test_channel
[−]
[src]
pub fn test_channel<I, SE, E>(
capacity: usize
) -> (Sender<I, SE, E>, Receiver<I, SE, E>)
Creates a new test channel with the given capacity, and returns a Sink for writing to it, and a Stream for reading from it.
I: Item, SE: SinkError, E: Error (of the Receiver)
Panics
Panics if capacity is 0.