pub struct DemuxSink {
pub demux: HashMap<u32, Arc<dyn RustCrateSink>>,
}Fields§
§demux: HashMap<u32, Arc<dyn RustCrateSink>>Trait Implementations§
Source§impl RustCrateSink for DemuxSink
impl RustCrateSink for DemuxSink
Source§fn instantiate(
&self,
client_host: &SourcePath,
) -> Result<Box<dyn FnOnce() -> ServerConfig>>
fn instantiate( &self, client_host: &SourcePath, ) -> Result<Box<dyn FnOnce() -> ServerConfig>>
Instantiate the sink as the source host connecting to the sink host.
Returns a thunk that can be called to perform mutations that instantiate the sink.
Source§fn instantiate_reverse(
&self,
server_host: &Arc<dyn Host>,
server_sink: Arc<dyn RustCrateServer>,
wrap_client_port: &dyn Fn(ServerConfig) -> ServerConfig,
) -> Result<ReverseSinkInstantiator>
fn instantiate_reverse( &self, server_host: &Arc<dyn Host>, server_sink: Arc<dyn RustCrateServer>, wrap_client_port: &dyn Fn(ServerConfig) -> ServerConfig, ) -> Result<ReverseSinkInstantiator>
Instantiate the sink, but as the sink host connecting to the source host.
Returns a thunk that can be called to perform mutations that instantiate the sink, taking a mutable reference to this sink.
Auto Trait Implementations§
impl Freeze for DemuxSink
impl !RefUnwindSafe for DemuxSink
impl Send for DemuxSink
impl Sync for DemuxSink
impl Unpin for DemuxSink
impl !UnwindSafe for DemuxSink
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<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> ToSinkBuild for T
impl<T> ToSinkBuild for T
§fn iter_to_sink_build(self) -> SendIterBuild<Self>
fn iter_to_sink_build(self) -> SendIterBuild<Self>
§fn stream_to_sink_build(self) -> SendStreamBuild<Self>where
Self: Sized + Stream,
fn stream_to_sink_build(self) -> SendStreamBuild<Self>where
Self: Sized + Stream,
Starts a [
SinkBuild] adaptor chain to send all items from self as a [Stream].