Packages

package javadsl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

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-Evend-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----------+
    | | currentLastEventId  |                     |    eventSources     | |
      +----------o----------+                     +----------o----------+
    |            ^                                           |            |
                 |      (EventSource, Future[Option[String]])|
    |            |                                           v            |
                 |                                +----------o----------+
    |            +--------------------------------o        unzip        | |
                 Future[Option[String]]           +----------o----------+
    |                                                        |            |
                                                  EventSource|
    |                                                        v            |
                                                  +----------o----------+
    |                                  +----------o       flatten       | |
                        ServerSentEvent|          +---------------------+
    |                                  v                                  |
     - - - - - - - - - - - - - - - - - o - - - - - - - - - - - - - - - - -

Ungrouped