This is an automated email from the ASF dual-hosted git repository. He-Pin pushed a change to branch feat-virtualize-dispatcher-v2 in repository https://gitbox.apache.org/repos/asf/pekko.git
discard 0794a191eb chore: remove unrelated local files from branch discard dc2c091983 chore(headers): add SPDX header to stream-tests application.conf\n\nMotivation: header check failed in CI; add SPDX header to test resource.\n\nCo-authored-by: Copilot <[email protected]> discard 80f41cc8b2 chore(headers): add missing headers via sbt headerCreate discard a4ba0a0cfd chore(stream-tests): move virtual thread test config to stream-tests module discard acf7e5c964 chore(stream-testkit): move virtual thread config to application.conf and simplify comment discard a4551fa546 feat(stream-testkit): enable virtual threads for JDK 21+ nightly builds add 29b723f043 fix: eliminate it.isEmpty and double-traversal risk in CompactByteString.apply(IterableOnce[Byte]) (#2875) add f5c37ba255 feat(stream): replace fanout publisher runtime with GraphStage bridge (#2874) add 52d249ac12 chore: clean branch with only virtualize changes This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (0794a191eb) \ N -- N -- N refs/heads/feat-virtualize-dispatcher-v2 (52d249ac12) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .jvmopts-ci | 15 ++ .../org/apache/pekko/util/ByteStringSpec.scala | 39 ++++ .../scala/org/apache/pekko/util/ByteString.scala | 5 +- .../pekko/stream/impl/FanoutProcessorSpec.scala | 144 ------------- .../stream/impl/FanoutPublisherBehaviorSpec.scala | 229 ++++++++++++++++++++ ...p.excludes => remove-fanout-processor.excludes} | 7 +- .../apache/pekko/stream/impl/FanoutProcessor.scala | 188 ---------------- .../stream/impl/FanoutPublisherBridgeStage.scala | 240 +++++++++++++++++++++ .../scala/org/apache/pekko/stream/impl/Sinks.scala | 12 +- 9 files changed, 536 insertions(+), 343 deletions(-) create mode 100644 .jvmopts-ci delete mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/impl/FanoutProcessorSpec.scala create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/impl/FanoutPublisherBehaviorSpec.scala copy stream/src/main/mima-filters/2.0.x.backwards.excludes/{remove-internal-unzip.excludes => remove-fanout-processor.excludes} (81%) delete mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/FanoutProcessor.scala create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/FanoutPublisherBridgeStage.scala --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
