tree 32488d97c2e1a85c92783357232a377457fb7622
parent c9cc576e1f4d477047f737cace79ed6b72c70350
author Lasse R.H. Nielsen <lrn@google.com> 1674691816 +0100
committer Lasse R.H. Nielsen <lrn@google.com> 1674691816 +0100

Simplify implementation of `StreamQueue`.

Only change in behavior is that all event seen by the original queue
while the transaction request is active, are forwarded to the transaction
immediately, and will still be visible after the transaction commits
or rejects.
The existing behavior was based on cancelling a stream subscription
and which events were visible depended on which commands had been
used to request those events.