Enum massa_models::streaming_step::StreamingStep

pub enum StreamingStep<T> {
    Started,
    Ongoing(T),
    Finished(Option<T>),
}

Streaming step cursor

Variants

Started

Started step, only when launching the streaming

Ongoing(T)

Ongoing step, as long as you are streaming

Finished(Option<T>)

Finished step, after all the information has been streamed

Also can keep an indicator of the last content streamed

Implementations

impl<T> StreamingStep<T>

pub fn finished(&self) -> bool

Indicates if the current step if finished or not without caring about the values

Trait Implementations

impl<T: Clone> Clone for StreamingStep<T>

fn clone(&self) -> StreamingStep<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for StreamingStep<T>

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

Formats the value using the given formatter.

impl<T, ST> Deserializer<StreamingStep<T>> for StreamingStepDeserializer<T, ST>

where ST: Deserializer<T>, T: Clone,

fn deserialize<'a, E: ParseError<&'a [u8]> + ContextError<&'a [u8]>>( &self, buffer: &'a [u8], ) -> IResult<&'a [u8], StreamingStep<T>, E>

Deserialize a value T from a buffer of u8.

impl<T: PartialEq> PartialEq for StreamingStep<T>

fn eq(&self, other: &StreamingStep<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T, ST> Serializer<StreamingStep<T>> for StreamingStepSerializer<T, ST>

where ST: Serializer<T>, T: Debug,

fn serialize( &self, value: &StreamingStep<T>, buffer: &mut Vec<u8>, ) -> Result<(), SerializeError>

Serialize a value T into a buffer of u8.

impl<T: Copy> Copy for StreamingStep<T>

impl<T: Eq> Eq for StreamingStep<T>

impl<T> StructuralPartialEq for StreamingStep<T>