raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Allow taking a stream snapshot of a stream that uses TLS (#29047)

Browse source
This commit is contained in:
Arnout Engelen 2020-05-13 09:14:04 +02:00 • committed by GitHub
parent 01b24fb4f5
commit 9a1d5191b9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 29 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala
View file

@ -967,7 +967,7 @@ private final case class SavedIslandData(
val props =
TLSActor.props(maxInputBuffer, tls.createSSLEngine, tls.verifySession, tls.closing).withDispatcher(dispatcher)
tlsActor = materializer.actorOf(props, islandName)
tlsActor = materializer.actorOf(props, "TLS-for-" + islandName)
def factory(id: Int) = new ActorPublisher[Any](tlsActor) {
override val wakeUpMsg = FanOut.SubstreamSubscribePending(id)
}