Searched defs:unbounded_channel_stream (Results 1 – 2 of 2) sorted by relevance
5 pub fn unbounded_channel_stream<T: Unpin>() -> (UnboundedSender<T>, impl Stream<Item = T>) { in unbounded_channel_stream() function
18 pub fn unbounded_channel_stream<T: Unpin>() -> (UnboundedSender<T>, impl Stream<Item = T>) { in unbounded_channel_stream() function