stream ALL initial adds

simplify internal state of ObserveMultiplexer