refactor: convert broadcast receiver into stream

[jacobkaufmann]

convert broadcast receivers for incoming bundles and invalidated bundles into streams by wrapping with BroadcastStream

other:

• fuse streams so that poll_next does not cause issues even if the stream has terminated.
• if the broadcast stream lags, then just move on. we can emit a warning here when we resolve #24.