pub enum CopyBothClientDoneReceive<S, C> {
Data(Conn<S, CopyBothClientDone, C>, Bytes),
Done(Conn<S, AwaitingReady, C>),
Error(Conn<S, Draining, C>, ErrorResponse),
}Expand description
Backend branch after the client closes its COPY BOTH half.
Variants§
Data(Conn<S, CopyBothClientDone, C>, Bytes)
One final opaque backend data chunk was received.
Done(Conn<S, AwaitingReady, C>)
The backend closed its half of the stream.
Error(Conn<S, Draining, C>, ErrorResponse)
COPY failed and entered drain-until-ready recovery.
Implementations§
Source§impl<S, C> CopyBothClientDoneReceive<S, C>
impl<S, C> CopyBothClientDoneReceive<S, C>
Sourcepub fn decode_replication(self) -> ReplicationClientDoneProjection<S, C>
pub fn decode_replication(self) -> ReplicationClientDoneProjection<S, C>
Decodes data received after the frontend half-close.
§Errors
Returns the connection with a decoding error for malformed known payloads.
Trait Implementations§
Auto Trait Implementations§
impl<S, C> !Freeze for CopyBothClientDoneReceive<S, C>
impl<S, C> RefUnwindSafe for CopyBothClientDoneReceive<S, C>where
S: RefUnwindSafe,
C: RefUnwindSafe,
impl<S, C> Send for CopyBothClientDoneReceive<S, C>
impl<S, C> Sync for CopyBothClientDoneReceive<S, C>
impl<S, C> Unpin for CopyBothClientDoneReceive<S, C>
impl<S, C> UnsafeUnpin for CopyBothClientDoneReceive<S, C>where
S: UnsafeUnpin,
impl<S, C> UnwindSafe for CopyBothClientDoneReceive<S, C>where
S: UnwindSafe,
C: UnwindSafe,
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more