tree 617641a3ee2e0f4e0613b849cc21ba95c1d73adf
parent f708371eff958ed0e12cfba3958001375522f581
author Lasse R.H. Nielsen <lrn@google.com> 1593545487 +0200
committer GitHub <noreply@github.com> 1593545487 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJe+5MPCRBK7hj4Ov3rIwAAdHIIACH2R21u1MRnfhYcPIpss9KC
 9E0Btt5aoZfSQ9jMAKnge53AsT9cqQnHrM3BZrYLqK4SjRUGDQwfns/TsPx9Dx8/
 R9kAfLoVgx758VYjt+TAOiTm1iywpcrT4vRpiUZFaaqImvz6Jr0sp9If6mxU6gs1
 92nGKDFCW5mLNnUQdMsiTH2ShBaDClg9JJgXHoCoBsy7SPR52xkH3pUUStzl4X6y
 gfNxIrW+4O7UqKeprWPb0EP6pHRBtpML9lhNm40ZUH9qvNcSaaFQF7EKYRlljgZh
 fXgOhhoKC7I418kYzEFxMbQh1wT7O8hRocCpJbCUyo1UiwOhXnVv/k9G3sSOpEY=
 =WSDW
 -----END PGP SIGNATURE-----
 

Make StreamQueue start listening immediately to broadcast streams. (#119)

When a `StreamQueue` is created for a broadcast stream, it didn't use to listen to the stream immediately, which means that any events sent before the first call to `next` (or any other queue request) would be silently lost. That makes an initial `peek` operation change the behavior of the queue, which is confusing to users.