HashMapPublisher

Publishes an event into the stream.

Sends the event to all subscribers in the HashMap.

Performs any cleaning up required when the stream is finished.

Notifies all subscribers that the stream is done and clears the HashMap to prevent any further events being delivered.

Subscribes an EventHandler to the stream so they can receive events.

Adds the subscriber to the HashMap and calls its onInit method.

Unsubscribes an EventHandler to the stream so they can stop receiving events.

Removes the subscriber from the HashMap.

Checks if an event signifies the end of the stream.

Wrapper method for doPublish that also stops the stream upon final events.

The HashMap of subscribers that receive events.