fn event_sink(
        &self,
    ) -> Box<Sink<SinkItem = SubgraphAssignmentProviderEvent, SinkError = ()> + Send> {
        let logger = self.logger.clone();
        Box::new(self.input.clone().sink_map_err(move |e| {
            error!(logger, "Component was dropped: {}", e);
        }))
    }
/// Get the wrapped event sink.
Get the wrapped event sink.
Get the wrapped event sink .
fn event_sink(
        &self,
    ) -> Box<Sink<SinkItem = SubgraphAssignmentProviderEvent, SinkError = ()> + Send> {
        let logger = self.logger.clone();
        Box::new(self.input.clone().sink_map_err(move |e| {
            error!(logger, "Component was dropped: {}", e);
        }))
    }
fn event_sink ( & self , ) -> Box < Sink < SinkItem = SubgraphAssignmentProviderEvent , SinkError = ( ) > + Send > { let logger = self . logger . clone ( ) ; Box :: new ( self . input . clone ( ) . sink_map_err ( move | e | { error ! ( logger " " e ) ; } ) ) }
Get the wrapped event sink.
Get the wrapped event sink .
&self
&self