Struct ValueStream 

pub struct ValueStream { /* private fields */ }

Implementations

impl ValueStream

pub fn from_value(value: impl Into<Value>) -> ValueStream

pub fn from_stream<T>(stream: T) -> ValueStream

where T: Stream<Item = Result<Value, Error>> + Send + 'static,

pub fn from_vec(records: Vec<Value>) -> ValueStream

pub fn from_iter<T, I>(iter: I) -> ValueStream

where T: Into<Value>, I: Iterator<Item = Result<T, Error>> + Send + 'static,

pub async fn next(&mut self) -> Option<Result<Value, Error>>

Returns the next record in the stream

pub async fn peek(&mut self) -> Option<Result<&Value, Error>>

Peek at the next record in the stream

pub async fn tap(&mut self) -> Result<(), Error>

Force the stream to preload at least one record, if there are more records to stream.

pub fn min_len(&self) -> usize

The stream will contain at least this number of elements

pub async fn collect(self) -> Result<Vec<Value>, Error>

pub async fn dup(&mut self) -> Result<ValueStream, Error>

pub fn try_clone(&self) -> Option<ValueStream>

pub async fn buffer(&mut self) -> Result<(), Error>

pub fn is_buffered(&self) -> bool

Returns true if the ValueStream is fully buffered (no remaining stream)

pub fn buffered_to_vec(&self) -> Vec<Value>

Returns a clone of only the currently buffered values Does not consume any stream data or wait for additional values

pub fn iter_mut(&mut self) -> impl Iterator<Item = &mut Value>

pub fn typed(self, ty: Type) -> ValueStream

Trait Implementations

impl Debug for ValueStream

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for ValueStream

fn default() -> ValueStream

Returns the “default value” for a type.

impl From<Value> for ValueStream

fn from(src: Value) -> ValueStream

Converts to this type from the input type.

impl From<Vec<Value>> for ValueStream

fn from(value: Vec<Value>) -> ValueStream

Converts to this type from the input type.

impl Stream for ValueStream

type Item = Result<Value, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut ValueStream>, cx: &mut Context<'_>, ) -> Poll<Option<<ValueStream as Stream>::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.