Struct daemon_engine::codecs::json::JsonCodec

pub struct JsonCodec<ENC, DEC, ERR> { /* private fields */ }

A codec for JSON encoding and decoding ENC is the type to encode, DEC is the type to decode, ERR is the error type to be returned for both operations

Implementations

impl<ENC, DEC, ERR> JsonCodec<ENC, DEC, ERR>where
    for<'de> DEC: Deserialize<'de> + Clone + Send + 'static,
    for<'de> ENC: Serialize + Clone + Send + 'static,
    ERR: From<Error> + From<Error> + 'static,

New builds an empty codec with associated types

pub fn new() -> JsonCodec<ENC, DEC, ERR>

Creates a new JsonCodec for shipping around raw bytes.

Trait Implementations

impl<ENC: Clone, DEC: Clone, ERR: Clone> Clone for JsonCodec<ENC, DEC, ERR>

fn clone(&self) -> JsonCodec<ENC, DEC, ERR>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<ENC: Debug, DEC: Debug, ERR: Debug> Debug for JsonCodec<ENC, DEC, ERR>

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

Formats the value using the given formatter.

impl<ENC, DEC, ERR> Decoder for JsonCodec<ENC, DEC, ERR>where
    for<'de> DEC: Deserialize<'de> + Clone + Send + 'static,
    for<'de> ENC: Serialize + Clone + Send + 'static,
    ERR: From<Error> + From<Error> + 'static,

Decoder impl parses json objects from bytes

type Item = DEC

The type of decoded frames.

type Error = ERR

The type of unrecoverable frame decoding errors.

fn decode(
    &mut self,
    buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

Attempts to decode a frame from the provided buffer of bytes.

fn decode_eof(
    &mut self,
    buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

A default method available to be called when there are no more bytes available to be read from the underlying I/O.

fn framed<T>(self, io: T) -> Framed<T, Self>where
    T: AsyncRead + AsyncWrite,
    Self: Encoder + Sized,

Provides a Stream and Sink interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data.

impl<ENC, DEC, ERR> Default for JsonCodec<ENC, DEC, ERR>where
    for<'de> DEC: Deserialize<'de> + Clone + Send + 'static,
    for<'de> ENC: Serialize + Clone + Send + 'static,
    ERR: From<Error> + From<Error> + 'static,

Default impl required for use with connections

fn default() -> JsonCodec<ENC, DEC, ERR>

Returns the “default value” for a type.

impl<ENC, DEC, ERR> Encoder for JsonCodec<ENC, DEC, ERR>where
    for<'de> DEC: Deserialize<'de> + Clone + Send + 'static,
    for<'de> ENC: Serialize + Clone + Send + 'static,
    ERR: From<Error> + From<Error> + 'static,

Encoder impl encodes object streams to bytes

type Item = ENC

The type of items consumed by the Encoder

type Error = ERR

The type of encoding errors.

fn encode(
    &mut self,
    data: Self::Item,
    buf: &mut BytesMut
) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.

impl<ENC: PartialEq, DEC: PartialEq, ERR: PartialEq> PartialEq<JsonCodec<ENC, DEC, ERR>> for JsonCodec<ENC, DEC, ERR>

fn eq(&self, other: &JsonCodec<ENC, DEC, ERR>) -> 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<ENC: Copy, DEC: Copy, ERR: Copy> Copy for JsonCodec<ENC, DEC, ERR>

impl<ENC, DEC, ERR> StructuralPartialEq for JsonCodec<ENC, DEC, ERR>