Struct JsonSerdeDeserializer 

pub struct JsonSerdeDeserializer<T> { /* private fields */ }

Typed deserializer: decodes each JSON document into your own T: serde::de::DeserializeOwned. No serde_json types appear in the pipeline. This is the flagship path.

Trait Implementations

impl<T> Clone for JsonSerdeDeserializer<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Debug for JsonSerdeDeserializer<T>

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

Formats the value using the given formatter.

impl<T> Deserializer<Owned<T>> for JsonSerdeDeserializer<T>

where T: DeserializeOwned + Send + 'static,

fn deserialize<'buf>( &mut self, raw: &RawPayload<'buf>, ack: &AckRef, out: &mut dyn EmitRecord<'buf, T>, ) -> Result<(), DeserError>

Decode raw, emitting each resulting record with the payload’s metadata and a clone of ack.