sink

BEAM-only sink for delivering a stream’s elements onto a Subject(a).

This is the dual of datastream/erlang/source.from_subject: together they let two parts of a system talk over a process-based channel without either side having to know the other’s stream representation.

Every public function in this module is gated on @target(erlang). On the JavaScript target the module still compiles, so import datastream/erlang/sink itself does not fail, but calling any function fails at the call site. The beam_only_marker constant exists solely to keep the module non-empty on the JavaScript target.

Values

into_subject

</>

pub fn into_subject(
  over stream: datastream.Stream(a),
  into subject: process.Subject(a),
) -> Nil

Drive stream to completion, sending each element to subject in source order. Returns Nil.

The function does not own the subject: it never closes or otherwise modifies it. Lifecycle (creation, naming, hand-off) stays with the caller, identical to from_subject on the source side.