franciscotln / callbag-create Goto Github PK

@staltz The case is:

const src = share(create(function producer(sink) {
  sink(1, 'A');
  sink(1, 'B');
}));

forEach(v => {
  console.log('OBS 1', v);
})(src);

forEach(v => {
  console.log('OBS 2', v);
})(src);

* Current behaviour:
// => OBS1 A
// => Error: talkback is not a function

* Expected behaviour (as RxJs):
// => OBS1 A
// => OBS1 B
OBS 2 never receives values.

If I wrap the body of the "producer" function into setTimeout(() => {}, 0); then it works as expected because all the sinks are hand-shaked otherwise the producer starts sinking before the sink gets the chance to receive the talkback function. It might be something in the implementation of create itself so before creating a PR to share I'd like to discuss it here.

Any thoughts if this is a share issue or create issue?