pub fn stream_rows(self) -> BoxStream<Row<'static, Simple>> {
        Box::new(
            self.stream_blocks()
                .map(Arc::new)
                .map(|block| {
                    let block_ref = BlockRef::Owned(block);
                    stream::iter_ok(Rows {
                        row: 0,
                        block_ref,
                        kind: marker::PhantomData,
                    })
                })
                .flatten(),
        )
    }
/// Method that produces a stream of rows
Method that produces a stream of rows
Method that produces a stream of rows
pub fn stream_rows(self) -> BoxStream<Row<'static, Simple>> {
        Box::new(
            self.stream_blocks()
                .map(Arc::new)
                .map(|block| {
                    let block_ref = BlockRef::Owned(block);
                    stream::iter_ok(Rows {
                        row: 0,
                        block_ref,
                        kind: marker::PhantomData,
                    })
                })
                .flatten(),
        )
    }
pub fn stream_rows ( self ) -> BoxStream < Row < ' static , Simple > > { Box :: new ( self . stream_blocks ( ) . map ( Arc :: new ) . map ( | block | { let block_ref = BlockRef :: Owned ( block ) ; stream :: iter_ok ( Rows { row : 0 , block_ref , kind : marker :: PhantomData , } ) } ) . flatten ( ) , ) }
Method that produces a stream of rows
Method that produces a stream of rows
self
self