PubSub.sink
A sink that will publish emitted messages to a Topic
Topic
.
Note that there is no backpressure from the topic, so care must be taken to not publish messages at a higher rate than that can be handled by subscribers.
If the topic does not have any subscribers when a message is published, or the topic actor is stopped, the message is sent to dead letters.
Dependency
This operator is included in:
- sbt
val AkkaVersion = "2.8.0" libraryDependencies += "com.typesafe.akka" %% "akka-stream-typed" % AkkaVersion
- Maven
<properties> <scala.binary.version>2.13</scala.binary.version> </properties> <dependencyManagement> <dependencies> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-bom_${scala.binary.version}</artifactId> <version>2.8.0</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-stream-typed_${scala.binary.version}</artifactId> </dependency> </dependencies>
- Gradle
def versions = [ ScalaBinary: "2.13" ] dependencies { implementation platform("com.typesafe.akka:akka-bom_${versions.ScalaBinary}:2.8.0") implementation "com.typesafe.akka:akka-stream-typed_${versions.ScalaBinary}" }
Signature
Reactive Streams semantics
cancels never
backpressures never