pub async fn write<T>(&mut self, pipe: Pipe, bytes: T) -> Result<()>
    where
        T: AsyncBufRead + Unpin + Copy,
    {
        join_all(
            self.drivers
                .iter_mut()
                .map(|x| match x {
                    LogDriver::ContainerRuntimeInterface(ref mut cri_logger) => {
                        cri_logger.write(pipe, bytes)
                    }
                })
                .collect::<Vec<_>>(),
        )
        .await
        .into_iter()
        .collect::<Result<Vec<_>>>()?;
        Ok(())
    }
/// Write the contents of the provided reader into all loggers.
Write the contents of the provided reader into all loggers.
Write the contents of the provided reader into all loggers .
pub async fn write<T>(&mut self, pipe: Pipe, bytes: T) -> Result<()>
    where
        T: AsyncBufRead + Unpin + Copy,
    {
        join_all(
            self.drivers
                .iter_mut()
                .map(|x| match x {
                    LogDriver::ContainerRuntimeInterface(ref mut cri_logger) => {
                        cri_logger.write(pipe, bytes)
                    }
                })
                .collect::<Vec<_>>(),
        )
        .await
        .into_iter()
        .collect::<Result<Vec<_>>>()?;
        Ok(())
    }
pub async fn write < T > ( & mut self , pipe : Pipe , bytes : T ) -> Result < ( ) > where T : AsyncBufRead + Unpin + Copy , { join_all ( self . drivers . iter_mut ( ) . map ( | x | match x { LogDriver :: ContainerRuntimeInterface ( ref mut cri_logger ) => { cri_logger . write ( pipe , bytes ) } } ) . collect :: < Vec < _ > > ( ) , ) . await . into_iter ( ) . collect :: < Result < Vec < _ > > > ( ) ? ; Ok ( ( ) ) }
Write the contents of the provided reader into all loggers.
Write the contents of the provided reader into all loggers .
&mut self
pipe
Pipe
bytes
T
&mut self
pipe
Pipe
bytes
T