Enum EthRlpxConnection 

pub enum EthRlpxConnection<N: NetworkPrimitives = EthNetworkPrimitives> {
    EthOnly(Box<EthStream<P2PStream<ECIESStream<TcpStream>>, N>>),
    Satellite(Box<RlpxSatelliteStream<ECIESStream<TcpStream>, EthStream<ProtocolProxy, N>>>),
}

Connection types that support the ETH protocol.

This can be either:

• A connection that only supports the ETH protocol
• A connection that supports the ETH protocol and at least one other RLPx protocol

Variants

EthOnly(Box<EthStream<P2PStream<ECIESStream<TcpStream>>, N>>)

A connection that only supports the ETH protocol.

Satellite(Box<RlpxSatelliteStream<ECIESStream<TcpStream>, EthStream<ProtocolProxy, N>>>)

A connection that supports the ETH protocol and at least one other RLPx protocol.

Implementations

impl<N: NetworkPrimitives> EthRlpxConnection<N>

pub fn start_send_broadcast( &mut self, item: EthBroadcastMessage<N>, ) -> Result<(), EthStreamError>

Same as [Sink::start_send] but accepts a EthBroadcastMessage instead.

pub fn start_send_raw( &mut self, msg: RawCapabilityMessage, ) -> Result<(), EthStreamError>

Sends a raw capability message over the connection

pub fn set_reject_block_announcements(&mut self, reject: bool)

Sets whether to reject block announcement messages (NewBlock, NewBlockHashes) before RLP decoding to avoid memory amplification from deserializing blocks that will be discarded.

Trait Implementations

impl<N: Debug + NetworkPrimitives> Debug for EthRlpxConnection<N>

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

Formats the value using the given formatter.

impl<N: NetworkPrimitives> From<EthStream<P2PStream<ECIESStream<TcpStream>>, N>> for EthRlpxConnection<N>

fn from(conn: EthStream<P2PStream<ECIESStream<TcpStream>>, N>) -> Self

Converts to this type from the input type.

impl<N: NetworkPrimitives> From<RlpxSatelliteStream<ECIESStream<TcpStream>, EthStream<ProtocolProxy, N>>> for EthRlpxConnection<N>

fn from( conn: RlpxSatelliteStream<ECIESStream<TcpStream>, EthStream<ProtocolProxy, N>>, ) -> Self

Converts to this type from the input type.

impl<N: NetworkPrimitives> Sink<EthMessage<N>> for EthRlpxConnection<N>

type Error = EthStreamError

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut Self>, item: EthMessage<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(())).

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

impl<N: NetworkPrimitives> Stream for EthRlpxConnection<N>

type Item = Result<EthMessage<N>, EthStreamError>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

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: 16 bytes

Size for each variant:

• EthOnly: 8 bytes
• Satellite: 8 bytes