Re: [PR] chore: Code clean up in MapAsyncUnordered [pekko]

2024-12-31 Thread via GitHub
He-Pin closed pull request #1659: chore: Code clean up in MapAsyncUnordered URL: https://github.com/apache/pekko/pull/1659 -- 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 un

[GH] (pekko): Workflow run "Build and test Pekko with Scala 3" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Build and test Pekko with Scala 3" on pekko.git has failed. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 646b7fd6b2a5909fa1c78940a6748ceb5302af5e / He-Pin chore: Code clean up in MapAsyncUnordered Report URL: https://github.com/apache/p

[GH] (pekko): Workflow run "Pull Requests" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Pull Requests" on pekko.git has failed. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 646b7fd6b2a5909fa1c78940a6748ceb5302af5e / He-Pin chore: Code clean up in MapAsyncUnordered Report URL: https://github.com/apache/pekko/actions/runs/125

Re: [PR] chore: Code clean up in MapAsyncUnordered [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1659: URL: https://github.com/apache/pekko/pull/1659#discussion_r1900318510 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala: ## @@ -1411,37 +1411,40 @@ private[stream] object Collect { override def preStart(): Unit =

Re: [PR] chore: Code clean up in MapAsyncUnordered [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1659: URL: https://github.com/apache/pekko/pull/1659#discussion_r1900318434 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala: ## @@ -1411,37 +1411,40 @@ private[stream] object Collect { override def preStart(): Unit =

[PR] chore: Code clean up in MapAsyncUnordered [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new pull request, #1659: URL: https://github.com/apache/pekko/pull/1659 Motivation: 1. Code clean up 2. tweak code more like mapasync 3. avoid double try pull when future is completed Modification: code clean up Result: easy to reason -- This i

[GH] (pekko-persistence-r2dbc): Workflow run "Nightly Tests (Pekko 1.0.x)" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Tests (Pekko 1.0.x)" on pekko-persistence-r2dbc.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 3923c60e58db34be0c2594339bfceedc29f12519 / PJ Fanning add 2025 to copyright (#183) Report URL: https://githu

[GH] (pekko-persistence-jdbc): Workflow run "Nightly Testing with Pekko 1.0" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Testing with Pekko 1.0" on pekko-persistence-jdbc.git has succeeded. Run started by GitHub user raboof (triggered by raboof). Head commit for run: 458fa081a72a8fda5096f7c787fdd3277ca0c4a6 / PJ Fanning add 2025 to copyright (#254) Report URL: https://github.co

[GH] (pekko-persistence-cassandra): Workflow run "Unit Tests" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Unit Tests" on pekko-persistence-cassandra.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 14bb09982a222046f36ee50467a5c8c81a492574 / PJ Fanning add 2025 to copyright (#248) Report URL: https://github.com/apache/

[PR] Update dependency-graph.yml [pekko-persistence-dynamodb]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #189: URL: https://github.com/apache/pekko-persistence-dynamodb/pull/189 issue where this CI still fails in every run -- 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 t

[GH] (pekko-connectors): Workflow run "Nightly Pekko 1.0 Builds" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Pekko 1.0 Builds" on pekko-connectors.git has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 711cabb5bc7309980703652d0415652d574ac265 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com

Re: [PR] add 2025 to copyright [pekko-persistence-cassandra]

2024-12-31 Thread via GitHub
pjfanning merged PR #248: URL: https://github.com/apache/pekko-persistence-cassandra/pull/248 -- 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: notificati

[GH] (pekko-persistence-dynamodb): Workflow run "Update Dependency Graph" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Update Dependency Graph" on pekko-persistence-dynamodb.git has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: b0968aba133fa1fdda8bd1da8ac3cde3269d4fc0 / PJ Fanning add 2025 to copyright (#188) Report URL: https://github.co

Re: [PR] add 2025 to copyright [pekko-persistence-dynamodb]

2024-12-31 Thread via GitHub
pjfanning merged PR #188: URL: https://github.com/apache/pekko-persistence-dynamodb/pull/188 -- 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: notificatio

Re: [PR] add 2025 to copyright [pekko-persistence-jdbc]

2024-12-31 Thread via GitHub
pjfanning merged PR #254: URL: https://github.com/apache/pekko-persistence-jdbc/pull/254 -- 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-u

[GH] (pekko-connectors-kafka): Workflow run "Nightly Build and Test" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Build and Test" on pekko-connectors-kafka.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: f15803e46d7dc9fafe44daed2e7336caf47a6131 / PJ Fanning add 2025 to copyright (#269) Report URL: https://github.com/

[GH] (pekko-persistence-cassandra): Workflow run "Unit Tests" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Unit Tests" on pekko-persistence-cassandra.git has failed. Run started by GitHub user mdedetrich (triggered by mdedetrich). Head commit for run: b518229db9b402f3ccc08f571be746ca3ebb3335 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>

[GH] (pekko-grpc): Workflow run "Publish Nightly" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Publish Nightly" on pekko-grpc.git has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 3319ceb5ba76447f2ea03dfcbd96963074c474ff / PJ Fanning add 2025 to copyright (#421) Report URL: https://github.com/apache/pekko-grpc/actions/r

[GH] (pekko-management): Workflow run "Nightly Tests" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Tests" on pekko-management.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: d86e9f551ca19961a9d23905005bb4c8a608f356 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com> Update

[GH] (pekko-http): Workflow run "Publish nightly snapshots and documentation" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Publish nightly snapshots and documentation" on pekko-http.git has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 8a2f240fc782a93e17666b9e2338fc8d60c6e51b / PJ Fanning add 2025 to copyright (#644) Report URL: https://github.co

[GH] (pekko-http): Workflow run "Nightly Builds" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Builds" on pekko-http.git has failed. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 8a2f240fc782a93e17666b9e2338fc8d60c6e51b / PJ Fanning add 2025 to copyright (#644) Report URL: https://github.com/apache/pekko-http/actions/runs/

[GH] (pekko-projection): Workflow run "Nightly Integration Tests for JDBC (Pekko 1.0.x)" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Integration Tests for JDBC (Pekko 1.0.x)" on pekko-projection.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: b9061628e91cea546f4918a36ce3a3ef5b9f6f95 / scala-steward-asf[bot] <147768647+scala-steward-asf[bo

[GH] (pekko): Workflow run "Nightly Builds (1.0)" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Builds (1.0)" on pekko.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: def84bf0c1338cbcdd65019d68453ea639d15ac3 / He-Pin(kerr) chore: fix failed in StreamConvertersSpec (#1655) Report URL: https://github.com

Re: [PR] add 2025 to copyright [pekko-persistence-r2dbc]

2024-12-31 Thread via GitHub
pjfanning merged PR #183: URL: https://github.com/apache/pekko-persistence-r2dbc/pull/183 -- 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-

[GH] (pekko-projection): Workflow run "Unit Tests" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Unit Tests" on pekko-projection.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: e8ebe7b3eec9a1b76993470cd6eca1f214f9056e / PJ Fanning add 2025 to copyright Report URL: https://github.com/apache/pekko-projection/act

[PR] add 2025 to copyright [pekko-persistence-r2dbc]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #183: URL: https://github.com/apache/pekko-persistence-r2dbc/pull/183 (no comment) -- 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 u

[PR] add 2025 to copyright [pekko-persistence-dynamodb]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #188: URL: https://github.com/apache/pekko-persistence-dynamodb/pull/188 (no comment) -- 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. T

[PR] add 2025 to copyright [pekko-persistence-cassandra]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #248: URL: https://github.com/apache/pekko-persistence-cassandra/pull/248 (no comment) -- 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.

[PR] add 2025 to copyright [pekko-persistence-jdbc]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #254: URL: https://github.com/apache/pekko-persistence-jdbc/pull/254 (no comment) -- 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 un

[PR] chore: Tweak withAttribuets in Flow [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new pull request, #1658: URL: https://github.com/apache/pekko/pull/1658 Motivation: To avoid https://github.com/apache/pekko/issues/1525 , I checked all the `Flow#withAttributes` usage. Modification: Move the `.withAttributes()` inside the `via(...)` R

[GH] (pekko): Workflow run "Scalafmt" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Scalafmt" on pekko.git has succeeded. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: 1d6f8f2ef9031ffa18b752ac6318fd497437a938 / He-Pin(kerr) Update stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipWithIndexSpec.scala Re

Re: [PR] chore: Implement zipWithIndex with statefulMap [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1657: URL: https://github.com/apache/pekko/pull/1657#discussion_r1900219449 ## stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipWithIndexSpec.scala: ## @@ -57,6 +57,7 @@ class FlowZipWithIndexSpec extends StreamSpec { //

[GH] (pekko): Workflow run "Scalafmt" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Scalafmt" on pekko.git has failed. Run started by GitHub user He-Pin (triggered by He-Pin). Head commit for run: b73ee9308dd9cbb17c11c2230418ed4e3dc6be6a / He-Pin(kerr) Update stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipWithIndexSpec.scala Repor

Re: [PR] chore: Implement zipWithIndex with statefulMap [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1657: URL: https://github.com/apache/pekko/pull/1657#discussion_r1900219304 ## stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowZipWithIndexSpec.scala: ## @@ -57,6 +57,8 @@ class FlowZipWithIndexSpec extends StreamSpec { //

[PR] chore: Implement zipWithIndex with statefulMap [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new pull request, #1657: URL: https://github.com/apache/pekko/pull/1657 Motivation: Performance, but it was reverted in https://github.com/apache/pekko/issues/1525 Modification: Reimplemented it in the right way. Result: Better performance Root c

Re: [PR] chore: fix failed in StreamConvertersSpec (#1655) [pekko]

2024-12-31 Thread via GitHub
He-Pin merged PR #1656: URL: https://github.com/apache/pekko/pull/1656 -- 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

[GH] (pekko-projection): Workflow run "Unit Tests" failed!

2024-12-31 Thread GitBox
The GitHub Actions job "Unit Tests" on pekko-projection.git has failed. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: e8ebe7b3eec9a1b76993470cd6eca1f214f9056e / PJ Fanning add 2025 to copyright Report URL: https://github.com/apache/pekko-projection/action

[PR] chore: fix failed in StreamConvertersSpec (#1655) [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new pull request, #1656: URL: https://github.com/apache/pekko/pull/1656 (cherry picked from commit def84bf0c1338cbcdd65019d68453ea639d15ac3) -- 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

[PR] add 2025 to copyright [pekko-projection]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #237: URL: https://github.com/apache/pekko-projection/pull/237 (no comment) -- 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 unsubscr

Re: [PR] chore: fix failed in StreamConvertersSpec [pekko]

2024-12-31 Thread via GitHub
He-Pin merged PR #1655: URL: https://github.com/apache/pekko/pull/1655 -- 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: [I] Failed: StreamConvertersSpec, an implementation is missing [pekko]

2024-12-31 Thread via GitHub
He-Pin closed issue #1653: Failed: StreamConvertersSpec, an implementation is missing URL: https://github.com/apache/pekko/issues/1653 -- 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 co

[PR] sbt 1.10.7 [pekko-quickstart-scala.g8]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #15: URL: https://github.com/apache/pekko-quickstart-scala.g8/pull/15 (no comment) -- 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 u

Re: [PR] upgrade sbt [pekko-site]

2024-12-31 Thread via GitHub
pjfanning merged PR #145: URL: https://github.com/apache/pekko-site/pull/145 -- 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...@p

[PR] upgrade sbt [pekko-site]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #145: URL: https://github.com/apache/pekko-site/pull/145 also copyright year -- 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 unsubsc

[PR] upgrade sbt and plugin [pekko-sbt-paradox]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #137: URL: https://github.com/apache/pekko-sbt-paradox/pull/137 (no comment) -- 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 unsubsc

Re: [PR] fix: avoid call finalizeStage more times than once. (#1650) [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on PR #1654: URL: https://github.com/apache/pekko/pull/1654#issuecomment-2566423994 @pjfanning Okay, Let's do this next weekend. -- 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 t

Re: [PR] fix: avoid call finalizeStage more times than once. (#1650) [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on PR #1654: URL: https://github.com/apache/pekko/pull/1654#issuecomment-2566421620 Can we hold off merging to patch branches for a few days so that the changes can be more widely reviewed? -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] chore: fix failed in StreamConvertersSpec [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on PR #1655: URL: https://github.com/apache/pekko/pull/1655#issuecomment-2566419966 since this was likely caused by https://github.com/apache/pekko/pull/1249, I think this should be backfit -- This is an automated message from the Apache Git Service. To respond to the

Re: [I] Failed: StreamConvertersSpec, an implementation is missing [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on issue #1653: URL: https://github.com/apache/pekko/issues/1653#issuecomment-2566419138 looks like this was caused by https://github.com/apache/pekko/pull/1249 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

Re: [PR] fix: avoid call finalizeStage more times than once. (#1650) [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on PR #1654: URL: https://github.com/apache/pekko/pull/1654#issuecomment-2566416818 It will cause problems in 1.0.x, but still, it may call twice `GraphStageLogic#postStop` in 1.1.x. -- This is an automated message from the Apache Git Service. To respond to the message, p

[PR] chore: fix failed in StreamConvertersSpec [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new pull request, #1655: URL: https://github.com/apache/pekko/pull/1655 Motivation: refs: https://github.com/apache/pekko/issues/1653 Modification: Implemented the splitIterator in test Result: Tests run ok. -- This is an automated message from the Ap

Re: [PR] fix: avoid call finalizeStage more times than once. (#1650) [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on PR #1654: URL: https://github.com/apache/pekko/pull/1654#issuecomment-2566410734 You keep raising PRs against the wrong branch. https://github.com/user-attachments/assets/cd828032-6fa5-4ac5-bef3-e4a2ccd9e571"; /> I don't think this should be merged to 1.1

[PR] fix: avoid call finalizeStage more times than once. (#1650) [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new pull request, #1654: URL: https://github.com/apache/pekko/pull/1654 (cherry picked from commit 7fef5b75f3a4e435f572d870758f364e1d65a84c) -- 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

Re: [I] Failed : java.lang.NullPointerException: IN ActorGraphInterpreterSpec [pekko]

2024-12-31 Thread via GitHub
He-Pin closed issue #1646: Failed : java.lang.NullPointerException: IN ActorGraphInterpreterSpec URL: https://github.com/apache/pekko/issues/1646 -- 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

Re: [PR] fix: avoid call finalizeStage more times than once. [pekko]

2024-12-31 Thread via GitHub
He-Pin merged PR #1650: URL: https://github.com/apache/pekko/pull/1650 -- 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

[I] Failed: StreamConvertersSpec, an implementation is missing [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new issue, #1653: URL: https://github.com/apache/pekko/issues/1653 The cause is : ```scala override def spliterator(): util.Spliterator[Unit] = ??? ``` ```scala [ERROR] [12/31/2024 20:11:02.525] [StreamConvertersSpec-pekko.actor.default-dispatcher-6

Re: [I] Feature Request: Add Flow#concatAllDeferred operator. [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on issue #1652: URL: https://github.com/apache/pekko/issues/1652#issuecomment-2566398230 For easy usage, I think that's ok, but at least, we need to update the doc about this, the current two pending PR is still valid. -- This is an automated message from the Apache Git S

Re: [I] Feature Request: Add Flow#concatAllDeferred operator. [pekko]

2024-12-31 Thread via GitHub
queimadus commented on issue #1652: URL: https://github.com/apache/pekko/issues/1652#issuecomment-2566396209 Is adding a new operator for this worth it? Since it's just almost the same as calling `flatMapConcat` directly? For more context, this is only really a problem when using the

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] add 2025 to copyright [pekko]

2024-12-31 Thread via GitHub
pjfanning merged PR #1651: URL: https://github.com/apache/pekko/pull/1651 -- 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...@pekk

Re: [D] Memory leak when using `flatMapPrefix`/`prefixAndTail` with `Concat` [pekko]

2024-12-31 Thread via GitHub
GitHub user He-Pin added a comment to the discussion: Memory leak when using `flatMapPrefix`/`prefixAndTail` with `Concat` @queimadus https://github.com/apache/pekko/issues/1652 GitHub link: https://github.com/apache/pekko/discussions/1566#discussioncomment-11705193 This is an automatic

Re: [D] Memory leak when using `flatMapPrefix`/`prefixAndTail` with `Concat` [pekko]

2024-12-31 Thread via GitHub
GitHub user He-Pin deleted a comment on the discussion: Memory leak when using `flatMapPrefix`/`prefixAndTail` with `Concat` @queimadus Happy New Year, I have come out with an idea. ```scala def concatAllDeferred[U >: Out](those: Graph[SourceShape[U], _]*): Repr[U] = concatLazy(Source.la

[I] Feature Request: Add Flow#concatAllDeferred operator. [pekko]

2024-12-31 Thread via GitHub
He-Pin opened a new issue, #1652: URL: https://github.com/apache/pekko/issues/1652 Motivation: The original issue is https://github.com/apache/pekko/pull/1623 and https://github.com/apache/pekko/discussions/1566 , which do help find some problems, but with how the current interpreter

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: [D] Memory leak when using `flatMapPrefix`/`prefixAndTail` with `Concat` [pekko]

2024-12-31 Thread via GitHub
GitHub user He-Pin added a comment to the discussion: Memory leak when using `flatMapPrefix`/`prefixAndTail` with `Concat` @queimadus Happy New Year, I have come out with an idea. ```scala def concatAllDeferred[U >: Out](those: Graph[SourceShape[U], _]*): Repr[U] = concatLazy(Source.lazy

Re: [PR] fix: avoid call finalizeStage more times than once. [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1650: URL: https://github.com/apache/pekko/pull/1650#discussion_r1900060536 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala: ## @@ -332,7 +335,10 @@ import pekko.stream.stage._ var i = 0 while (i < log

Re: [PR] fix: avoid call finalizeStage more times than once. [pekko]

2024-12-31 Thread via GitHub
samueleresca commented on PR #1650: URL: https://github.com/apache/pekko/pull/1650#issuecomment-2566348645 Overall, it looks good. Shouldn't the change also be applied to the `finish` finalizeStage call? https://github.com/apache/pekko/blob/c8810cd73567a69edc35e605d9557545e789b63e/st

[GH] (pekko-http): Workflow run "Nightly Builds" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Nightly Builds" on pekko-http.git has succeeded. Run started by GitHub user He-Pin (triggered by pjfanning). Head commit for run: 93d3dc855ba2cc7732c0029385f47f61b0b942e0 / scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com> Update specs2-c

Re: [I] nightlies and link validation failing because of repository.apache.org blockage [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on issue #1585: URL: https://github.com/apache/pekko/issues/1585#issuecomment-2566335762 @raboof on source of strain that we put on repository.apache.org is from https://github.com/pjfanning/sbt-pekko-build This has logic to find the latest snapshot versions by scr

Re: [PR] reimplement fix for akka/pekko cluster [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on code in PR #1594: URL: https://github.com/apache/pekko/pull/1594#discussion_r1900043585 ## .github/workflows/build-test-prValidation.yml: ## @@ -101,6 +101,53 @@ jobs: -Dpekko.log.timestamps=true \ validatePullRequest + pekko-class

Re: [PR] add 2025 to copyright [pekko-connectors-kafka]

2024-12-31 Thread via GitHub
pjfanning merged PR #269: URL: https://github.com/apache/pekko-connectors-kafka/pull/269 -- 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-u

[GH] (pekko-connectors-kafka): Workflow run "CI" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "CI" on pekko-connectors-kafka.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: 04839ef12eac53e7e883ea75264665e04b5a85a4 / PJ Fanning add 2025 to copyright Report URL: https://github.com/apache/pekko-connectors-kafk

[GH] (pekko-connectors): Workflow run "CI" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "CI" on pekko-connectors.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: c752a40a818ce69c5cb753c795e7d41aef8df301 / PJ Fanning add 2025 to copyright Report URL: https://github.com/apache/pekko-connectors/actions/run

Re: [I] BroadcastHub can loop many times to clean the ring [pekko]

2024-12-31 Thread via GitHub
He-Pin closed issue #1627: BroadcastHub can loop many times to clean the ring URL: https://github.com/apache/pekko/issues/1627 -- 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. T

Re: [I] Nightly build 1.1.x is actually testing 1.0.x [pekko]

2024-12-31 Thread via GitHub
He-Pin closed issue #1647: Nightly build 1.1.x is actually testing 1.0.x URL: https://github.com/apache/pekko/issues/1647 -- 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 uns

Re: [PR] add 2025 to copyright [pekko-http]

2024-12-31 Thread via GitHub
pjfanning merged PR #644: URL: https://github.com/apache/pekko-http/pull/644 -- 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...@p

Re: [PR] add 2025 to copyright [pekko-grpc]

2024-12-31 Thread via GitHub
pjfanning merged PR #421: URL: https://github.com/apache/pekko-grpc/pull/421 -- 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...@p

Re: [PR] fix: avoid call finalizeStage more times than once. [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1649: URL: https://github.com/apache/pekko/pull/1649#discussion_r1900033509 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala: ## @@ -239,6 +239,9 @@ import pekko.stream.stage._ logics(i).handlers.length }

Re: [PR] fix: avoid call finalizeStage more times than once. [pekko]

2024-12-31 Thread via GitHub
He-Pin commented on code in PR #1649: URL: https://github.com/apache/pekko/pull/1649#discussion_r1900033365 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala: ## @@ -239,6 +239,9 @@ import pekko.stream.stage._ logics(i).handlers.length }

Re: [PR] fix: Use 1.1.x build in 1.1.x nightly build [pekko]

2024-12-31 Thread via GitHub
He-Pin merged PR #1648: URL: https://github.com/apache/pekko/pull/1648 -- 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

[GH] (pekko-grpc): Workflow run "Validate and test" is working again!

2024-12-31 Thread GitBox
The GitHub Actions job "Validate and test" on pekko-grpc.git has succeeded. Run started by GitHub user pjfanning (triggered by pjfanning). Head commit for run: c61f7babf587df710a7989220b4858c757650af5 / PJ Fanning add 2025 to copyright Report URL: https://github.com/apache/pekko-grpc/actions/

[PR] add 2025 to copyright [pekko-connectors-kafka]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #269: URL: https://github.com/apache/pekko-connectors-kafka/pull/269 (no comment) -- 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 un

[PR] add 2025 to copyright [pekko-connectors]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #935: URL: https://github.com/apache/pekko-connectors/pull/935 (no comment) -- 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 unsubscr

[PR] add 2025 to copyright [pekko-grpc]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #421: URL: https://github.com/apache/pekko-grpc/pull/421 (no comment) -- 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

[PR] add 2025 to copyright [pekko-http]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #644: URL: https://github.com/apache/pekko-http/pull/644 (no comment) -- 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

[PR] add 2025 to copyright [pekko]

2024-12-31 Thread via GitHub
pjfanning opened a new pull request, #1651: URL: https://github.com/apache/pekko/pull/1651 (no comment) -- 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-ma

Re: [PR] fix: avoid call finalizeStage more times than once. [pekko]

2024-12-31 Thread via GitHub
pjfanning commented on code in PR #1650: URL: https://github.com/apache/pekko/pull/1650#discussion_r199418 ## stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala: ## @@ -240,6 +240,9 @@ import pekko.stream.stage._ logics(i).handlers.length