Enum bolt_client::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>(
    buf_stream: &'_ mut BufStream<T>
) -> Result<Message, Error> where
    T: Unpin + AsyncRead + AsyncWrite, 

Trait Implementations

impl Debug for Message

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

Formats the value using the given formatter.

impl Deserialize for Message

impl From<Failure> for Message

fn from(message: Failure) -> Message

Performs the conversion.

impl From<Init> for Message

fn from(message: Init) -> Message

Performs the conversion.

impl From<Record> for Message

fn from(message: Record) -> Message

Performs the conversion.

impl From<Run> for Message

fn from(message: Run) -> Message

Performs the conversion.

impl From<Success> for Message

fn from(message: Success) -> Message

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<Message, 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<Success, 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<Record, 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<Init, 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<Run, 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<Failure, Error>

Performs the conversion.

impl TryFrom<MessageBytes> for Message

type Error = Error

The type returned in the event of a conversion error.

fn try_from(message_bytes: MessageBytes) -> Result<Message, 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, 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>, Error>

Performs the conversion.