Struct ByteDecoderModel 

pub struct ByteDecoderModel<T: Clone + Send + 'static, D: BufDecoder<T> + Send + 'static> {
    pub data_out: Output<T>,
    /* private fields */
}

Byte stream decoder model.

Fields

data_out: Output<T>

Decoded data.

Implementations

impl<T, D> ByteDecoderModel<T, D>

where T: Clone + Send + 'static, D: BufDecoder<T> + Send + 'static,

pub async fn bytes_in( &mut self, data: Bytes, _: &Context<Self>, env: &mut D::DecoderEnv, )

Input bytes – input port.

Trait Implementations

impl<T, D> Debug for ByteDecoderModel<T, D>

where T: Clone + Send + 'static, D: BufDecoder<T> + Send + 'static,

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

Formats the value using the given formatter.

impl<'de, T: Clone + Send + 'static, D: BufDecoder<T> + Send + 'static> Deserialize<'de> for ByteDecoderModel<T, D>

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T, D> Model for ByteDecoderModel<T, D>

where T: Clone + Send + 'static, D: BufDecoder<T> + Send + 'static,

type Env = <D as BufDecoder<T>>::DecoderEnv

Helper struct for internal non-state model data that cannot (or should not) be serialized and persisted.

fn register_schedulables( cx: &mut BuildContext<'_, impl ProtoModel<Model = Self>>, ) -> ModelRegistry

Generates a registry of inputs schedulable with the schedulable! macro.

fn init( self, _: &Context<Self>, _: &mut Self::Env, ) -> impl Future<Output = InitializedModel<Self>> + Send

Performs asynchronous model initialization.

impl<T: Clone + Send + 'static, D: BufDecoder<T> + Send + 'static> Serialize for ByteDecoderModel<T, D>

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.