This stream processing stage establishes a continuous source of server-sent events from the given URI.

A single source of server-sent events is obtained from the URI. Once completed, either normally or by failure, a next one is obtained thereby sending a Last-Event-ID header if available. This continues in an endless cycle.

The shape of this processing stage is a source of server-sent events; to take effect it must be connected and run. Progress (including termination) is controlled by the connected flow or sink, e.g. a retry delay can be implemented by streaming the materialized values of the handler via a throttle.

+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +
                                              +---------------------+
|                                             |       trigger       | |
                                              +----------o----------+
|                                                        |            |
                                           Option[String]|
|                                                        v            |
             Option[String]                   +----------o----------+
|            +------------------------------->o        merge        | |
             |                                +----------o----------+
|            |                                           |            |
             |                             Option[String]|
|            |                                           v            |
  +--------o--------+                         +----------o----------+
| |   lastEventId   |                         |   continuousEvents  | |
  +--------o--------+                         +----------o----------+
|            ^                                           |            |
             |     ServerSentEvent (including delimiters)|
|            |                                           v            |
             |                                +----------o----------+
|            +--------------------------------o        bcast        | |
             ServerSentEvent (incl. delim.)   +----------o----------+
|                                                        |            |
                   ServerSentEvent (including delimiters)|
|                                                        v            |
                                              +----------o----------+
|                                  +----------o       events        | |
                    ServerSentEvent|          +---------------------+
|                                  v                                  |
 - - - - - - - - - - - - - - - - - o - - - - - - - - - - - - - - - - -