Enum bolt_proto::Message

pub enum Message {
    Init(Init),
    Run(Run),
    DiscardAll,
    PullAll,
    AckFailure,
    Reset,
    Record(Record),
    Success(Success),
    Failure(Failure),
    Ignored,
}

Variants

Init(Init)

Run(Run)

DiscardAll

PullAll

AckFailure

Reset

Record(Record)

Success(Success)

Failure(Failure)

Ignored

Methods

impl Message

pub async fn from_stream<'_, T: Unpin + AsyncRead + AsyncWrite>(
    buf_stream: &'_ mut BufStream<T>
) -> Result<Message, Error>

Trait Implementations

impl Debug for Message

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

Formats the value using the given formatter.

impl Deserialize for Message

impl From<Failure> for Message

fn from(message: Failure) -> Self

Performs the conversion.

impl From<Init> for Message

fn from(message: Init) -> Self

Performs the conversion.

impl From<Record> for Message

fn from(message: Record) -> Self

Performs the conversion.

impl From<Run> for Message

fn from(message: Run) -> Self

Performs the conversion.

impl From<Success> for Message

fn from(message: Success) -> Self

Performs the conversion.

impl Marker for Message

fn get_marker(&self) -> Result<u8, Error>

impl Serialize for Message

fn try_into_bytes(self) -> Result<Bytes, Error>

impl Signature for Message

fn get_signature(&self) -> u8

impl TryFrom<Arc<Mutex<Bytes>>> for Message

type Error = Error

The type returned in the event of a conversion error.

fn try_from(value: Arc<Mutex<Bytes>>) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Message> for Failure

type Error = Error

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Message> for Init

type Error = Error

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Message> for Record

type Error = Error

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Message> for Run

type Error = Error

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Message> for Success

type Error = Error

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryInto<Bytes> for Message

type Error = Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<Bytes, Self::Error>

Performs the conversion.

impl TryInto<Vec<Bytes>> for Message

type Error = Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<Vec<Bytes>, Self::Error>

Performs the conversion.