gatherEvents

Establishes a WebSocket connection and starts receiving events in real time. Waits until an initial connection is established before starting to emit all unprocessed events stored locally.

This flow is hot and updated based on the internal event trigger mechanism.

Once the local event storage is exhausted, it will emit EventStreamData.IsUpToDate, signaling that the app is up-to-date with the remote sources.