pub enum EthSnapMessage<N: NetworkPrimitives = EthNetworkPrimitives> {
Eth(EthMessage<N>),
Snap(SnapProtocolMessage),
}Expand description
A message carried by an EthSnapStream: either an eth message or a snap/2 message.
Variants§
Eth(EthMessage<N>)
An eth protocol message.
Snap(SnapProtocolMessage)
A snap/2 (EIP-8189) protocol message.
Trait Implementations§
Source§impl<N: Debug + NetworkPrimitives> Debug for EthSnapMessage<N>
impl<N: Debug + NetworkPrimitives> Debug for EthSnapMessage<N>
Source§impl<St, N> Sink<EthSnapMessage<N>> for EthSnapStream<St, N>where
St: Stream<Item = Result<BytesMut>> + Sink<Bytes, Error = Error> + Unpin,
N: NetworkPrimitives,
impl<St, N> Sink<EthSnapMessage<N>> for EthSnapStream<St, N>where
St: Stream<Item = Result<BytesMut>> + Sink<Bytes, Error = Error> + Unpin,
N: NetworkPrimitives,
Source§type Error = EthStreamError
type Error = EthStreamError
The type of value produced by the sink when an error occurs.
Source§fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>
fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>
Attempts to prepare the
Sink to receive a value. Read moreSource§fn start_send(
self: Pin<&mut Self>,
item: EthSnapMessage<N>,
) -> Result<(), Self::Error>
fn start_send( self: Pin<&mut Self>, item: EthSnapMessage<N>, ) -> Result<(), Self::Error>
Begin the process of sending a value to the sink.
Each call to this function must be preceded by a successful call to
poll_ready which returned Poll::Ready(Ok(())). Read moreAuto Trait Implementations§
impl<N = BasicNetworkPrimitives<EthPrimitives, EthereumTxEnvelope<TxEip4844WithSidecar>>> !Freeze for EthSnapMessage<N>
impl<N> RefUnwindSafe for EthSnapMessage<N>where
EthMessage<N>: RefUnwindSafe,
impl<N> Send for EthSnapMessage<N>where
EthMessage<N>: Send,
impl<N> Sync for EthSnapMessage<N>where
EthMessage<N>: Sync,
impl<N> Unpin for EthSnapMessage<N>where
EthMessage<N>: Unpin,
impl<N> UnsafeUnpin for EthSnapMessage<N>where
EthMessage<N>: UnsafeUnpin,
impl<N> UnwindSafe for EthSnapMessage<N>where
EthMessage<N>: UnwindSafe,
Blanket Implementations§
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> Pointable for T
impl<T> Pointable for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere
S: Into<Dispatch>,
§fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 144 bytes
Size for each variant:
Eth: 144 bytesSnap: 144 bytes