Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2025-01-03 Thread via GitHub
He-Pin merged PR #1623: URL: https://github.com/apache/pekko/pull/1623 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@pekko.a

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2025-01-03 Thread via GitHub
He-Pin commented on PR #1623: URL: https://github.com/apache/pekko/pull/1623#issuecomment-2568886736 Okay, let me remove the backport label from it -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on PR #1623: URL: https://github.com/apache/pekko/pull/1623#issuecomment-2566384697 @queimadus continue here https://github.com/apache/pekko/issues/1652 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on PR #1623: URL: https://github.com/apache/pekko/pull/1623#issuecomment-2566380367 @queimadus Hi, I realized that the origin issue of `concatAllLazy` can not be fixed with the current implementation of Interpreter. So I have to add a new operator for this. ```scal

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
He-Pin commented on code in PR #1623: URL: https://github.com/apache/pekko/pull/1623#discussion_r1894921805 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala: ## @@ -237,7 +239,9 @@ import pekko.util.ccompat.JavaConverters._ override def onU

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
He-Pin commented on code in PR #1623: URL: https://github.com/apache/pekko/pull/1623#discussion_r1894921062 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala: ## @@ -237,7 +239,9 @@ import pekko.util.ccompat.JavaConverters._ override def onU

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
He-Pin commented on code in PR #1623: URL: https://github.com/apache/pekko/pull/1623#discussion_r1894921062 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala: ## @@ -237,7 +239,9 @@ import pekko.util.ccompat.JavaConverters._ override def onU

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
queimadus commented on code in PR #1623: URL: https://github.com/apache/pekko/pull/1623#discussion_r1894909443 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala: ## @@ -237,7 +239,9 @@ import pekko.util.ccompat.JavaConverters._ override def

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
pjfanning commented on code in PR #1623: URL: https://github.com/apache/pekko/pull/1623#discussion_r1894897237 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala: ## @@ -237,7 +239,9 @@ import pekko.util.ccompat.JavaConverters._ override def

Re: [PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
He-Pin commented on code in PR #1623: URL: https://github.com/apache/pekko/pull/1623#discussion_r1894895662 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala: ## @@ -237,7 +239,9 @@ import pekko.util.ccompat.JavaConverters._ override def onU

[PR] fix: Fix a leak in PrefixAndTail operator. [pekko]

2024-12-22 Thread via GitHub
He-Pin opened a new pull request, #1623: URL: https://github.com/apache/pekko/pull/1623 Motivation: Fix @queimadus's report in https://github.com/apache/pekko/discussions/1566 Modification: When the upstream finishes quickly but the downstream is not pulled, a leak can happen, s