PubSub.sink
A sink that will publish emitted messages to a 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:
val PekkoVersion = "1.1.3"
libraryDependencies += "org.apache.pekko" %% "pekko-stream-typed" % PekkoVersion
<properties>
<scala.binary.version>2.13</scala.binary.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.apache.pekko</groupId>
<artifactId>pekko-bom_${scala.binary.version}</artifactId>
<version>1.1.3</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.apache.pekko</groupId>
<artifactId>pekko-stream-typed_${scala.binary.version}</artifactId>
</dependency>
</dependencies>
def versions = [
ScalaBinary: "2.13"
]
dependencies {
implementation platform("org.apache.pekko:pekko-bom_${versions.ScalaBinary}:1.1.3")
implementation "org.apache.pekko:pekko-stream-typed_${versions.ScalaBinary}"
}
Signature¶
Reactive Streams semantics¶
cancels never
backpressures never
1.1.3