Enum CopyBothReceive 

pub enum CopyBothReceive<S, C> {
    Data(Conn<S, CopyBoth, C>, Bytes),
    Done(Conn<S, CopyBothServerDone, C>),
    Error(Conn<S, Draining, C>, ErrorResponse),
}

Backend branch while both COPY directions remain open.

Variants

Data(Conn<S, CopyBoth, C>, Bytes)

One opaque backend data chunk was received.

Done(Conn<S, CopyBothServerDone, C>)

The backend closed its half of the stream.

Error(Conn<S, Draining, C>, ErrorResponse)

COPY failed and entered drain-until-ready recovery.

Implementations

impl<S, C> CopyBothReceive<S, C>

pub fn decode_replication(self) -> ReplicationProjection<S, C>

Decodes a COPY BOTH data branch as a walsender message.

Errors

Returns the connection with a decoding error for malformed known payloads.

Trait Implementations

impl<S: Debug, C: Debug> Debug for CopyBothReceive<S, C>

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

Formats the value using the given formatter.