WIP enabled pending groupBy test - shouldn't it be valid like this?
because of the `primaryOutputs.isClosed` in the openSubstream phase
we don't open substreams after the master subscription is closed.
Am I missing something? // cc @drewhk