Struct DocumentDecoder 

pub struct DocumentDecoder<Op: Operation, Event> { /* private fields */ }

The decoder of a reply that is one document: classify reads the document, and end makes it the operation’s end.

Implementations

impl<Op: Operation, Event> DocumentDecoder<Op, Event>

pub fn new( classify: fn(&str) -> WireEvent<Event>, end: fn(Event) -> Result<Op::End, ProviderError>, ) -> Self

The decoder that reads a reply with classify and ends it with end.

Trait Implementations

impl<'id, Op: Operation, Event> Decoder<'id, Op> for DocumentDecoder<Op, Event>

type Event = Event

The wire’s typed event, produced by this decoder’s classifier.

fn classify(&self, frame: WireFrame) -> WireEvent<Event>

Decode and classify one frame. A JSON wire MUST delegate to a classifier in crate::providers::internal::wire, so the decode-then-validate policy is not re-derived per provider.

fn decode( &mut self, event: Event, out: Out<'id, Op>, ) -> Result<Flow, ProviderError>

Write one Known event into the reply. An error ends the reply with it.

fn eof(&mut self, out: Out<'id, Op>) -> Result<Flow, ProviderError>

The frames ran out without an end. A decoder that already saw the provider’s end, in a form the provider sends before its last frame, ends the reply here; otherwise the reply is truncated.