Struct dencode::BytesCodec

pub struct BytesCodec {}

A simple codec that ships bytes around

Example

use bytes::Bytes;
use futures::{SinkExt, TryStreamExt};
use futures::io::Cursor;
use dencode::{BytesCodec, Framed};

let mut buf = vec![];
// Cursor implements AsyncRead and AsyncWrite
let cur = Cursor::new(&mut buf);
let mut framed = Framed::new(cur, BytesCodec {});

framed.send(Bytes::from("Hello World!")).await?;

while let Some(bytes) = framed.try_next().await? {
   dbg!(bytes);
}

Trait Implementations

impl Clone for BytesCodec

fn clone(&self) -> BytesCodec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BytesCodec

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

Formats the value using the given formatter.

impl Decoder for BytesCodec

type Item = Bytes

The type of items returned by decode

type Error = Error

The type of decoding errors.

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

Decode an item from the src BytesMut into an item

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

Called when the input stream reaches EOF, signaling a last attempt to decode

impl Encoder<Bytes> for BytesCodec

type Error = Error

The type of encoding errors.

fn encode(&mut self, src: Bytes, dst: &mut BytesMut) -> Result<(), Self::Error>

Encodes an item into the BytesMut provided by dst.

impl Copy for BytesCodec