Function websocat::broadcast_reuse_peer::connection_reuser[][src]

pub fn connection_reuser<F: FnOnce() -> BoxedNewPeerFuture>(
    s: &mut GlobalState,
    inner_peer: F,
    buffer_size: usize,
    queue_len: usize
) -> BoxedNewPeerFuture