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

fix: Fix a leak in PrefixAndTail operator. (#1623)

Browse source
This commit is contained in:
He-Pin(kerr) 2025-01-03 21:46:40 +08:00 • committed by GitHub
parent 2b6d2dc0a0
commit d34927b56b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala
View file

@ -237,7 +237,9 @@ import pekko.util.ccompat.JavaConverters._
override def onUpstreamFinish(): Unit = {
if (!prefixComplete) {
// This handles the unpulled out case as well
emit(out, (builder.result(), Source.empty), () => completeStage())
val prefix = builder.result();
builder = null // free for GC
emit(out, (prefix, Source.empty), () => completeStage())
} else {
if (!tailSource.isClosed) tailSource.complete()
completeStage()