Trait exocore_transport::transport::TransportServiceHandle

pub trait TransportServiceHandle: Future<Output = ()> + Send + Unpin + 'static {
    type Sink: Sink<OutEvent, Error = Error> + Send + Unpin + 'static;
    type Stream: Stream<Item = InEvent> + Send + Unpin + 'static;
    fn on_started(&self) -> TransportHandleOnStart;
    fn get_sink(&mut self) -> Self::Sink;
    fn get_stream(&mut self) -> Self::Stream;
}

Handle to a transport to be used by a service of a cell.

Associated Types

type Sink: Sink<OutEvent, Error = Error> + Send + Unpin + 'static

type Stream: Stream<Item = InEvent> + Send + Unpin + 'static

Required methods

fn on_started(&self) -> TransportHandleOnStart

fn get_sink(&mut self) -> Self::Sink

fn get_stream(&mut self) -> Self::Stream

Implementors

impl TransportServiceHandle for HttpTransportServiceHandle

impl TransportServiceHandle for Libp2pTransportServiceHandle

impl<TLeft, TRight> TransportServiceHandle for EitherTransportServiceHandle<TLeft, TRight> where
    TLeft: TransportServiceHandle,
    TRight: TransportServiceHandle,