1 - triagedhelp wantedt:stream
Métriques du dépôt
- Stars
- (13 277 stars)
- Métriques de merge PR
- (Merge moyen 8j 19h) (10 PRs mergées en 30 j)
Description
Implement it in terms of BroadcastHub instead (after https://github.com/akka/akka/pull/21183 merged). Implementation can be as simple as roughly:
object Sink {
...
def asPublisher[T](fanout: Boolean): Sink[T, Publisher[T]] = {
if (fanout) BroadcastHub.sink(bufferSize).mapMaterializedValue { src =>
new Publisher {
def subscribe(s: Subscriber): Unit = src.runWith(Sink.fromSubscriber(s))
}
}
}
...
}
While this might be somewhat less efficient (although not sure!), it removes a rather ugly old class and its dependencies in one simple move.