the current implementation will fail in single connection mode when running under a load balancer with multiple processes/containers since there is no guarantee that the second request will hit the same server instance as the one with the stream token.

ideally there should be a strategy for storing tokens in shared memory like redis