// Forwards data received from a stream of archive clients provided by the returned sender to a
// stream of sockets provided by calls to |subscribe|.
Forwards data received from a stream of archive clients provided by the returned sender to a
stream of sockets provided by calls to |subscribe|.
Forwards data received from a stream of archive clients provided by the returned sender to a stream of sockets provided by calls to |subscribe| .
pub fn create_archive_forwarder(
    ) -> (mpsc::UnboundedSender<ClientEnd<rc::ArchiveIteratorMarker>>, Self) {
        let (rx_sender, rx_receiver) = mpsc::unbounded::<ClientEnd<rc::ArchiveIteratorMarker>>();
        (
            rx_sender,
            Bridge::create_forwarder(|sender| read_from_sequence_of_archives(rx_receiver, sender)),
        )
    }
pub fn create_archive_forwarder ( ) -> ( mpsc :: UnboundedSender < ClientEnd < rc :: ArchiveIteratorMarker > > , Self ) { let ( rx_sender , rx_receiver ) = mpsc :: unbounded :: < ClientEnd < rc :: ArchiveIteratorMarker > > ( ) ; ( rx_sender , Bridge :: create_forwarder ( | sender | read_from_sequence_of_archives ( rx_receiver , sender ) ) , ) }
Forwards data received from a stream of archive clients provided by the returned sender to a
stream of sockets provided by calls to |subscribe|.
Forwards data received from a stream of archive clients provided by the returned sender to a stream of sockets provided by calls to |subscribe| .