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;
    pub fn on_started(&self) -> TransportHandleOnStart;
    pub fn get_sink(&mut self) -> Self::Sink;
    pub 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

Loading content...

Required methods

pub fn on_started(&self) -> TransportHandleOnStart

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

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

Loading content...

Implementors

impl TransportServiceHandle for HTTPTransportServiceHandle

type Sink = MpscHandleSink

type Stream = MpscHandleStream

pub fn on_started(&self) -> TransportHandleOnStart

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

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

impl TransportServiceHandle for Libp2pTransportServiceHandle

type Sink = SinkMapErr<Sender<OutEvent>, fn(_: SendError) -> Error>

type Stream = Receiver<InEvent>

pub fn on_started(&self) -> TransportHandleOnStart

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

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

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

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

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

pub fn on_started(&self) -> TransportHandleOnStart

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

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

Loading content...