StreamNodeX<T> extension

Adds stream subscription helpers directly on AsyncValue nodes.

on

• ZenithNode<AsyncValue<T>>

Methods

watch(ZenithRef ref, Stream<T> stream) → StreamSubscription<T>

Available on ZenithNode<AsyncValue<T>>, provided by the StreamNodeX extension

Subscribes to stream and writes each event to this node, guarding every mutation with ref's lifecycle.