Function queue_ext::queue_channel

pub fn queue_channel<Q, Item, F1, R, F2>(
    q: Q,
    f1: F1,
    f2: F2
) -> (QueueSender<QueueStream<Q, Item, F2>, Item, F1, R>, QueueStream<Q, Item, F2>)where
    Q: Sized + Unpin + Clone,
    F1: Fn(&mut QueueStream<Q, Item, F2>, Action<Item>) -> Reply<R>,
    F2: Fn(Pin<&mut Q>, &mut Context<'_>) -> Poll<Option<Item>> + Clone + Unpin,