input flags are received multiple times. Investigate whether it is a problem.

[bheijden]

A previous solution was to change line flag = flag.pipe(spy(flag_name, node)) to flag = flag.pipe(spy(flag_name, node), ops.take(1), ops.merge(rx.never())) in the function init_channels(...). However, this sometimes deadlocks the environment during the reset right after all pipelines are initialized, as one of the nodes does not receive the input flags, even though they were send.

Adding line flag.pipe(spy(f'sub_{flag_name}', node)).subscribe(print) right before flag = flag.pipe(spy(flag_name, node), ops.take(1), ops.merge(rx.never())) demonstrates that flags are still received, but not cannot pass through the ops.take(1).