Struct hydro_deploy::hydroflow_crate::ports::DemuxSink

pub struct DemuxSink {
    pub demux: HashMap<u32, Arc<dyn HydroflowSink>>,
}

Fields

demux: HashMap<u32, Arc<dyn HydroflowSink>>

Trait Implementations

impl HydroflowSink for DemuxSink

fn as_any(&self) -> &dyn Any

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.

fn instantiate_reverse( &self, server_host: &Arc<dyn Host>, server_sink: Arc<dyn HydroflowServer>, 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.