Server-sent Events (SSE) Connector

The SSE connector provides a continuous source of server-sent events recovering from connection failure.

Artifacts

sbt

libraryDependencies += "com.lightbend.akka" %% "akka-stream-alpakka-sse" % "0.15"

Maven

<dependency>
  <groupId>com.lightbend.akka</groupId>
  <artifactId>akka-stream-alpakka-sse_2.12</artifactId>
  <version>0.15</version>
</dependency>

Gradle

dependencies {
  compile group: 'com.lightbend.akka', name: 'akka-stream-alpakka-sse_2.12', version: '0.15'
}

Usage

Simply define an EventSource by giving a URI, a function for sending HTTP requests and an optional initial value for Last-Evend-ID header:

Scala

val eventSource = EventSource(Uri(s"http://$host:$port"), send, Some("2"), 1.second)

Then happily consume ServerSentEvents:

Scala

val events =
  eventSource.throttle(1, 500.milliseconds, 1, ThrottleMode.Shaping).take(nrOfSamples).runWith(Sink.seq)