// Forwards data received from a stream of sockets provided by the returned sender to another
// stream of sockets provided by calls to |subscribe|.
Forwards data received from a stream of sockets provided by the returned sender to another
stream of sockets provided by calls to |subscribe|.
Forwards data received from a stream of sockets provided by the returned sender to another stream of sockets provided by calls to |subscribe| .
pub fn create_socket_forwarder() -> (mpsc::UnboundedSender<zx::Socket>, Self) {
        let (rx_sender, rx_receiver) = mpsc::unbounded::<zx::Socket>();
        (
            rx_sender,
            Bridge::create_forwarder(|sender| read_from_sequence_of_sockets(rx_receiver, sender)),
        )
    }
pub fn create_socket_forwarder ( ) -> ( mpsc :: UnboundedSender < zx :: Socket > , Self ) { let ( rx_sender , rx_receiver ) = mpsc :: unbounded :: < zx :: Socket > ( ) ; ( rx_sender , Bridge :: create_forwarder ( | sender | read_from_sequence_of_sockets ( rx_receiver , sender ) ) , ) }
Forwards data received from a stream of sockets provided by the returned sender to another
stream of sockets provided by calls to |subscribe|.
Forwards data received from a stream of sockets provided by the returned sender to another stream of sockets provided by calls to |subscribe| .