Enum EthRlpxConnection

pub enum EthRlpxConnection<N = EthNetworkPrimitives>
where
    N: NetworkPrimitives,
{
    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> EthRlpxConnection<N>

where N: NetworkPrimitives,

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

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

Trait Implementations

impl<N> Debug for EthRlpxConnection<N>

where N: Debug + NetworkPrimitives,

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

Formats the value using the given formatter.

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

where N: NetworkPrimitives,

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

Converts to this type from the input type.

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

where N: NetworkPrimitives,

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

Converts to this type from the input type.

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

where N: NetworkPrimitives,

type Error = EthStreamError

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

fn poll_ready( self: Pin<&mut EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut EthRlpxConnection<N>>, item: EthMessage<N>, ) -> Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::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 EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>>

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

impl<N> Stream for EthRlpxConnection<N>

where N: NetworkPrimitives,

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

Values yielded by the stream.

fn poll_next( self: Pin<&mut EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Option<<EthRlpxConnection<N> as Stream>::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