Struct Take 

pub struct Take;

The declaration of a transport whose client keeps the payload: it is handed a BytesMut of its own.

The buffer arrives as it was written, so Vec::from and BytesMut::freeze turn it into what the client speaks without copying it. See PayloadForm.

Examples

use std::io;

use ruststream::{Bytes, BytesMut, OutgoingMessage, Publisher, Take};

/// The client queues the record and sends it later, so it keeps the buffer: `freeze` turns it
/// into the `Bytes` the client speaks without a copy.
struct QueuedPublisher {
    producer: Producer,
}

impl Publisher for QueuedPublisher {
    type Payload = Take;
    type Error = io::Error;
    type Options = ();

    async fn publish(
        &self,
        msg: OutgoingMessage<'_, BytesMut>,
        _options: Option<&()>,
    ) -> io::Result<()> {
        let topic = msg.name();
        self.producer.send(topic, msg.into_payload().freeze()).await
    }
}

Trait Implementations

impl Clone for Take

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Take

impl Debug for Take

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

Formats the value using the given formatter.

impl Default for Take

fn default() -> Self

Returns the “default value” for a type.

impl Eq for Take

impl Hash for Take

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Take

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PayloadForm for Take

type Form<'a> = BytesMut

The payload as this form carries it: &'a [u8] for Lend, BytesMut for Take.

impl StructuralPartialEq for Take