pub fn seek<'a>(&'a mut self, from: SeekFrom) -> impl Stream<Item = (usize, io::Error)> + 'a {
        Gen::new(|co| {
            async move {
                let &mut Self { ref mut subscribed, .. } = self;

                let mut stream = FuturesUnordered::from_iter(
                    subscribed
                        .iter_mut()
                        .map(|(indice, writer)| async move { (indice, writer.seek(from).await) }),
                );

                while let Some((indice, why)) = stream.next().await {
                    if let Err(why) = why {
                        co.yield_((indice, why)).await;
                    }
                }
            }
        })
    }
/// Seek all writers to a specific point.
Seek all writers to a specific point.
Seek all writers to a specific point .
pub fn seek<'a>(&'a mut self, from: SeekFrom) -> impl Stream<Item = (usize, io::Error)> + 'a {
        Gen::new(|co| {
            async move {
                let &mut Self { ref mut subscribed, .. } = self;
                let mut stream = FuturesUnordered::from_iter(
                    subscribed
                        .iter_mut()
                        .map(|(indice, writer)| async move { (indice, writer.seek(from).await) }),
                );
                while let Some((indice, why)) = stream.next().await {
                    if let Err(why) = why {
                        co.yield_((indice, why)).await;
                    }
                }
            }
        })
    }
pub fn seek < ' a > ( & ' a mut self , from : SeekFrom ) -> impl Stream < Item = ( usize , io :: Error ) > + ' a { Gen :: new ( | co | { async move { let & mut Self { ref mut subscribed , .. } = self ; let mut stream = FuturesUnordered :: from_iter ( subscribed . iter_mut ( ) . map ( | ( indice , writer ) | async move { ( indice , writer . seek ( from ) . await ) } ) , ) ; while let Some ( ( indice , why ) ) = stream . next ( ) . await { if let Err ( why ) = why { co . yield_ ( ( indice , why ) ) . await ; } } } } ) }
Seek all writers to a specific point.
Seek all writers to a specific point .
&'a mut self
from
SeekFrom
&'a mut self
from
SeekFrom