watchStream<T> method

StreamSubscription<T> watchStream<T>(
  1. ZenithNode<AsyncValue<T>> node,
  2. Stream<T> stream
)

Subscribes to stream and writes events to node, cancelling on disposal.

Implementation

StreamSubscription<T> watchStream<T>(
  ZenithNode<AsyncValue<T>> node,
  Stream<T> stream,
) {
  return ref.watchStream(node, stream);
}