Value Members

1.  object EventSource

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

   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 - - - - - - - - - - - - - - - - -