pub trait HydroflowSource: Send + Sync {
    // Required methods
    fn source_path(&self) -> SourcePath;
    fn record_server_config(&self, config: ServerConfig);
    fn host(&self) -> Arc<dyn Host>;
    fn server(&self) -> Arc<dyn HydroflowServer>;
    fn record_server_strategy(&self, config: ServerStrategy);

    // Provided methods
    fn wrap_reverse_server_config(&self, config: ServerConfig) -> ServerConfig { ... }
    fn send_to(&self, sink: &dyn HydroflowSink) { ... }
}

Required Methods§

Provided Methods§

Implementors§