fn from_writers<W, C>(
        writers: &[W],
        pool_tx: &Sender<CompressorMessage>,
        writer_txs: &[Sender<Receiver<WriterMessage>>],
    ) -> Vec<Self>
    where
        W: Write + Send + 'static,
        C: Compressor,
    {
        writers
            .iter()
            .zip(writer_txs.iter())
            .map(|(_w, writer_tx)| Self::new::<C>(pool_tx.clone(), writer_tx.clone()))
            .collect()
    }
/// Zip together all writers and senders to create a set of [`PooledWriter`]s.
///
/// # Arguments
/// - `writers` - The conventional [`Write`] writers that are being exchanged.
/// - `pool_tx` - The channel to send uncompressed bytes to the compressor pool.
/// - `writer_txs` - The `Send` ends of the channels that transmit the `Receiver` ends of the one-shot
///                  channels, which will be consumed when the compressor sends the compressed bytes.
Zip together all writers and senders to create a set of [`PooledWriter`]s.
Zip together all writers and senders to create a set of [ ` PooledWriter ` ] s .
fn from_writers<W, C>(
        writers: &[W],
        pool_tx: &Sender<CompressorMessage>,
        writer_txs: &[Sender<Receiver<WriterMessage>>],
    ) -> Vec<Self>
    where
        W: Write + Send + 'static,
        C: Compressor,
    {
        writers
            .iter()
            .zip(writer_txs.iter())
            .map(|(_w, writer_tx)| Self::new::<C>(pool_tx.clone(), writer_tx.clone()))
            .collect()
    }
fn from_writers < W , C > ( writers : & [ W ] , pool_tx : & Sender < CompressorMessage > , writer_txs : & [ Sender < Receiver < WriterMessage > > ] , ) -> Vec < Self > where W : Write + Send + ' static , C : Compressor , { writers . iter ( ) . zip ( writer_txs . iter ( ) ) . map ( | ( _w , writer_tx ) | Self :: new :: < C > ( pool_tx . clone ( ) , writer_tx . clone ( ) ) ) . collect ( ) }
Zip together all writers and senders to create a set of [`PooledWriter`]s.
Zip together all writers and senders to create a set of [ ` PooledWriter ` ] s .
writers
&[W]
pool_tx
&Sender<CompressorMessage>
writer_txs
&[Sender<Receiver<WriterMessage>>]
writers
&[W]
The conventional [`Write`] writers that are being exchanged.
The conventional [ ` Write ` ] writers that are being exchanged .
pool_tx
&Sender<CompressorMessage>
The channel to send uncompressed bytes to the compressor pool.
The channel to send uncompressed bytes to the compressor pool .
writer_txs
&[Sender<Receiver<WriterMessage>>]
The `Send` ends of the channels that transmit the `Receiver` ends of the one-shot
channels, which will be consumed when the compressor sends the compressed bytes.
The ` Send ` ends of the channels that transmit the ` Receiver ` ends of the one - shot channels which will be consumed when the compressor sends the compressed bytes .