bind method

  1. @override
void bind(
  1. FutureOr<void> handler(
    1. MutatorContext context,
    2. T value
    )
)
override

Binds a notifies from source into handler callback Allow Store mutation via PipelineContext in handler

Implementation

@override
void bind(FutureOr<void> Function(MutatorContext context, T value) handler) {
  final sub = _stream.listen($pipelineRef.$handle(_stream, handler));
  $pipelineRef.$disposeQueue.add(sub.cancel);
}