pipe

Creates a new subscription node from an input stream or subjection

• Type

  type fork = (arg$: Stream | Subjection) => Subjection;

• Details

  • A stream subscription operation that returns a new subscription node
  • When the input stream unsubscribes, the new subscription node will also unsubscribe
  • When the input stream completes, the new subscription node will also complete