This is an automated email from the ASF dual-hosted git repository.
hepin pushed a change to branch dropFutureSourceInJava
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit 89bd15c778 chore: Remove Source#future in javadsl
add 01f2265fb2 chore: optimize Source#future and Source#futureSource
(#2560)
add f735cca1a5 chore: Remove CollectionUtil (#2582)
add d93ac96e94 chore(deps): bump coursier/setup-action from 2.0.0 to 2.0.1
(#2587)
add 226f256fe6 chore(deps): bump scalacenter/sbt-dependency-submission
(#2586)
add c2be56159b Update sbt-scalafix to 0.14.5 (#2588)
add fd396a6fa4 Update netty-handler, netty-transport to 4.2.9.Final (#2589)
add 306cd43bff try to reduce confusion about signals in persistence
implementations (#2585)
add 280e1ec892 chore: Deprecate Source#future in javadsl (#2555) (#2593)
add b972df6a2b create CI jobs to test and publish snapshots for 1.5.x
(#2597)
add df1dabcde1 Update lz4-java to 1.10.2 (#2598)
add d3721365b0 chore(deps): bump scalacenter/sbt-dependency-submission
(#2599)
add ded28854d3 Update scalafmt-core to 3.10.3 (#2604)
add fbfbcddd23 Update logback-classic to 1.5.23 (#2603)
add c96fee6ec2 Update biz.aQute.bndlib to 7.2.0 (#2602)
add ffe69d8172 2026 (#2605)
add 9054b94320 chore(deps): bump coursier/setup-action from 2.0.1 to 2.0.2
(#2606)
add 9febbcf73d chore: Pekko now contains features form Akka 2.7.0 (#2609)
add d91ef0ab59 Update sbt, scripted-plugin to 1.12.0 (#2614)
add 993ff1fe19 Update logback-classic to 1.5.24 (#2610)
add 404959c8aa Update junit-jupiter-engine to 6.0.2 (#2613)
add 03fa322362 Update sbt-unidoc to 0.6.1 (#2611)
add e88c38875d Update protobuf-java to 4.33.3 (#2612)
add 0428719fac Delete CollectionUtil.scala (#2615)
add 065551c772 chore(deps): bump sbt/setup-sbt from 1.1.14 to 1.1.15
(#2618)
add 44799471fe chore(deps): bump scala-steward-org/scala-steward-action
(#2619)
add 91107b140e Update biz.aQute.bndlib to 7.2.1 (#2621)
add 845ad5f4c9 Update commons-codec to 1.20.0 (#2623)
add ba49f67b13 Update protobuf-java to 4.33.4 (#2622)
add c76f814815 onDownstreamFinish() has been removed (#2627)
add 285793b42a Update scalafmt-core to 3.10.4
add 63212bde59 Reformat with scalafmt 3.10.4
add e087c98871 Add 'Reformat with scalafmt 3.10.4' to
.git-blame-ignore-revs
add 6d5a0ec2d7 Update logback-classic to 1.5.25 (#2628)
add 8031d622d1 add test case that shows we don't retry FailedSources
(#2624)
add ac7b5ef066 chore: unfold import selectors in scalafmt
add 4dd60f592e chore: add "unfold import selectors in scalafmt" to
.git-blame-ignore-revs
add 029c5572a5 fix: Fix recoverWith on Failed stage. (#2631)
add 7657845482 chore(deps): bump actions/checkout from 6.0.1 to 6.0.2
(#2636)
add 04ae68719e Update scalafmt-core to 3.10.5 (#2643)
add 1087070246 Update sbt, scripted-plugin to 1.12.1 (#2642)
add 4412669b5e Update metrics-core, metrics-jvm to 4.2.38 (#2641)
add 30a05ff6e8 Update sbt-develocity to 1.4.4 (#2640)
add 55acb59f76 Update logback-classic to 1.5.26 (#2638)
add c2fb2f7df2 Update jackson-core to 2.21.0 and 3.0.4 (#2639)
add c80506c157 Update lz4-java to 1.10.3 (#2637)
add da60eaed79 Update logback-classic to 1.5.27 (#2646)
add 0d131a4b09 Update protobuf-java to 4.33.5 (#2647)
add b85f2391d3 Update scalafmt-core to 3.10.6 (#2649)
add e42884d45c Update commons-codec to 1.21.0 (#2648)
add c42175f6f0 chore(deps): bump scala-steward-org/scala-steward-action
(#2635)
add d773de57a5 Update sbt, scripted-plugin to 1.12.2 (#2653)
add b9853db050 chore(deps): bump scala-steward-org/scala-steward-action
(#2650)
add 36a7f76d3b chore(deps): bump sbt/setup-sbt from 1.1.15 to 1.1.16
(#2660)
add 815f63115e chore(deps): bump scala-steward-org/scala-steward-action
(#2659)
add 45a1a09e87 chore(deps): bump coursier/cache-action from 7.0.0 to 8.0.0
(#2658)
add 462f53cdd5 chore: Update test tls cipher (#2656)
add 7cd4d5fb00 docs: use different reference for deserialization security
(#2661)
add dd14721534 Update logback-classic to 1.5.28 (#2654)
add 076fa2e633 Update sbt-develocity to 1.4.5 (#2652)
add 4ad50d2815 Update netty-handler, netty-transport to 4.2.10.Final
(#2655)
add 5c339c514f Update logback-classic to 1.5.29 (#2662)
add c36dcdebd5 Update scalafmt-core to 3.10.7 (#2663)
add 91fc255093 Update logback-classic to 1.5.32 (#2667)
add b85e4d863c Update junit-jupiter-engine to 6.0.3 (#2668)
add 2f7f9db64e Update sbt, scripted-plugin to 1.12.3 (#2669)
add a09310fe1a Update sbt-mima-plugin to 1.1.5 (#2670)
add 43483148c9 docs: replace ACM link with authors' site (#2666)
add 49103f99fb chore(deps): bump coursier/setup-action from 2.0.2 to 2.0.3
(#2673)
add 5f17483d5d chore(deps): bump sbt/setup-sbt from 1.1.16 to 1.1.17
(#2671)
add 8f960373df chore(deps): bump coursier/cache-action from 8.0.0 to 8.0.1
(#2672)
add c9906c60fc Revert recent changes to recoverWith (#2674)
add 4496a3dd78 Update jackson-core to 3.1.0 (#2682)
add 84c058a980 Update typesafe:config to 1.4.6 (#2680)
add 705da0f7cd Update sbt, scripted-plugin to 1.12.4 (#2681)
add d8516c4652 Update jackson-core to 2.21.1 (#2679)
add 7f274b0f92 Delete scala-steward.yml (#2685)
add 123979ae9a Update sbt-scalafix to 0.14.6 (#2686)
add e11e65f4f4 Update jctools-core to 4.0.6 (#2687)
add 9ed7d3232e Add dependabot support for GitHub Actions on branch 1.5.x
(#2695)
add f61a9ec585 chore(deps): bump sbt/setup-sbt from 1.1.17 to 1.1.18
(#2699)
add c779b0ec74 Update protobuf-java to 4.34.0 (#2703)
add e6ebe2b8dc Unpin sbt-java-formatter (#2704)
add 051eae9729 Update sbt, scripted-plugin to 1.12.5 (#2709)
add e07ce86a25 Unpin jackson-annotations (#2710)
add fcd7fa2dab Update lz4-java to 1.10.4 (#2711)
add 2939de02db fix: Fix recoverWith with add missing attempt back. (#2712)
add 1500134afa chore: Remove Source#future in javadsl
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 (89bd15c778)
\
N -- N -- N refs/heads/dropFutureSourceInJava (1500134afa)
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:
.git-blame-ignore-revs | 7 +
.github/dependabot.yml | 5 +
.github/workflows/binary-compatibility-checks.yml | 12 +-
.github/workflows/build-test-prValidation.yml | 24 +-
.github/workflows/dependency-graph.yml | 6 +-
.github/workflows/format.yml | 2 +-
.github/workflows/generate-doc-check.yml | 6 +-
.github/workflows/headers.yml | 6 +-
.github/workflows/link-validator.yml | 8 +-
.github/workflows/nightly-1.0-builds.yml | 18 +-
.github/workflows/nightly-1.1-builds.yml | 18 +-
.github/workflows/nightly-1.2-builds.yml | 18 +-
.github/workflows/nightly-1.3-builds.yml | 18 +-
.github/workflows/nightly-1.4-builds.yml | 20 +-
...ghtly-1.4-builds.yml => nightly-1.5-builds.yml} | 29 +-
.github/workflows/nightly-builds-aeron.yml | 6 +-
.github/workflows/nightly-builds.yml | 18 +-
.github/workflows/publish-1.0-docs.yml | 6 +-
.github/workflows/publish-1.0-nightly.yml | 6 +-
.github/workflows/publish-1.1-docs.yml | 6 +-
.github/workflows/publish-1.1-nightly.yml | 6 +-
.github/workflows/publish-1.2-docs.yml | 6 +-
.github/workflows/publish-1.2-nightly.yml | 6 +-
.github/workflows/publish-1.3-docs.yml | 6 +-
.github/workflows/publish-1.3-nightly.yml | 8 +-
.github/workflows/publish-1.4-docs.yml | 6 +-
.github/workflows/publish-1.4-nightly.yml | 6 +-
...ish-1.4-nightly.yml => publish-1.5-nightly.yml} | 12 +-
.github/workflows/publish-2.0-docs.yml | 6 +-
.github/workflows/publish-nightly.yml | 6 +-
.github/workflows/scala-steward.yml | 45 ---
.github/workflows/stage-release-candidate.yml | 6 +-
.github/workflows/timing-tests.yml | 6 +-
.scala-steward.conf | 3 -
.scalafmt.conf | 3 +-
NOTICE | 2 +-
README.md | 1 +
.../org/apache/pekko/actor/ActorSystemSpec.scala | 11 +-
.../pekko/actor/CoordinatedShutdownSpec.scala | 9 +-
.../apache/pekko/actor/ReceiveTimeoutSpec.scala | 3 +-
.../org/apache/pekko/actor/SchedulerSpec.scala | 9 +-
.../pekko/actor/SupervisorHierarchySpec.scala | 3 +-
.../actor/dispatch/BalancingDispatcherSpec.scala | 3 +-
.../apache/pekko/event/LoggingReceiveSpec.scala | 2 +-
.../scala/org/apache/pekko/pattern/AskSpec.scala | 4 +-
.../apache/pekko/actor/typed/SupervisionSpec.scala | 15 +-
.../actor/typed/internal/ActorSystemSpec.scala | 3 +-
.../typed/delivery/DurableProducerQueue.scala | 6 +-
.../delivery/internal/ProducerControllerImpl.scala | 3 +-
.../pekko/actor/typed/internal/Supervision.scala | 3 +-
.../scala/org/apache/pekko/actor/ActorPath.scala | 9 +-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 9 +-
.../pekko/actor/LightArrayRevolverScheduler.scala | 11 +-
.../org/apache/pekko/dispatch/Mailboxes.scala | 6 +-
.../scala/org/apache/pekko/event/EventStream.scala | 3 +-
.../org/apache/pekko/event/LoggingReceive.scala | 5 +-
.../pekko/io/dns/internal/TcpDnsClient.scala | 3 +-
.../org/apache/pekko/pattern/CircuitBreaker.scala | 3 +-
.../org/apache/pekko/routing/ConsistentHash.scala | 6 +-
.../scala/org/apache/pekko/util/Collections.scala | 24 ++
.../org/apache/pekko/util/FrequencySketch.scala | 9 +-
.../scala/org/apache/pekko/util/SWARUtil.scala | 3 +-
.../typed/delivery/ReliableDeliveryBenchmark.scala | 5 +-
build.sbt | 8 +-
.../internal/ShardingProducerControllerImpl.scala | 9 +-
.../cluster/sharding/typed/internal/Murmur2.scala | 5 +-
.../internal/ReplicatedShardingExtensionImpl.scala | 3 +-
.../typed/delivery/DeliveryThroughputSpec.scala | 10 +-
.../cluster/sharding/ClusterShardingSettings.scala | 3 +-
.../pekko/cluster/sharding/ShardCoordinator.scala | 3 +-
.../pekko/cluster/sharding/ShardRegion.scala | 12 +-
.../internal/LeastShardAllocationStrategy.scala | 5 +-
.../RandomizedBrainResolverIntegrationSpec.scala | 13 +-
.../sharding/MultiDcClusterShardingSpec.scala | 3 +-
.../sharding/MultiNodeClusterShardingConfig.scala | 3 +-
.../JoinConfigCompatCheckShardingSpec.scala | 3 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 7 +-
.../ddata/typed/internal/ReplicatorBehavior.scala | 57 ++-
.../delivery/ReliableDeliverySerializerSpec.scala | 6 +-
.../org/apache/pekko/cluster/ClusterDaemon.scala | 9 +-
.../org/apache/pekko/cluster/ClusterEvent.scala | 3 +-
.../org/apache/pekko/cluster/MembershipState.scala | 3 +-
.../cluster/routing/ClusterRouterConfig.scala | 3 +-
.../ClusterAccrualFailureDetectorSpec.scala | 3 +-
.../pekko/cluster/ClusterDeathWatchSpec.scala | 3 +-
.../apache/pekko/cluster/JoinInProgressSpec.scala | 3 +-
.../apache/pekko/cluster/LeaderLeavingSpec.scala | 3 +-
.../cluster/MembershipChangeListenerUpSpec.scala | 6 +-
.../pekko/cluster/MinMembersBeforeUpSpec.scala | 6 +-
.../pekko/cluster/MultiDcSunnyWeatherSpec.scala | 5 +-
.../apache/pekko/cluster/NodeMembershipSpec.scala | 6 +-
.../org/apache/pekko/cluster/SplitBrainSpec.scala | 3 +-
.../org/apache/pekko/cluster/StressSpec.scala | 14 +-
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 27 +-
.../pekko/cluster/ReachabilityPerfSpec.scala | 15 +-
.../pekko/cluster/StartupWithOneThreadSpec.scala | 6 +-
.../apache/pekko/cluster/VectorClockPerfSpec.scala | 12 +-
.../pekko/cluster/sbr/SplitBrainResolverSpec.scala | 21 +-
.../org/apache/pekko/cluster/ddata/ORMap.scala | 14 +-
.../apache/pekko/cluster/ddata/Replicator.scala | 3 +-
docs/src/main/paradox/general/remoting.md | 2 +-
docs/src/main/paradox/remoting-artery.md | 2 +-
docs/src/main/paradox/remoting.md | 2 +-
docs/src/main/paradox/serialization.md | 2 +-
docs/src/main/paradox/stream/stream-customize.md | 2 +-
.../paradox/typed/durable-state/persistence.md | 7 +
docs/src/main/paradox/typed/persistence.md | 4 +-
.../docs/actor/io/dns/DnsCompileOnlyDocSpec.scala | 12 +-
.../test/scala/docs/cluster/FactorialBackend.scala | 2 +-
legal/PekkoNotice.txt | 2 +-
legal/pekko-actor-jar-notice.txt | 2 +-
legal/pekko-remote-jar-notice.txt | 2 +-
.../leveldb/EventsByPersistenceIdStage.scala | 3 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 3 +-
.../persistence/scalatest/OptionalTests.scala | 5 +-
.../typed/ReplicatedAuctionExampleSpec.scala | 6 +-
.../persistence/typed/internal/BehaviorSetup.scala | 3 +-
.../typed/BasicPersistentBehaviorTest.java | 3 +-
.../typed/BasicPersistentBehaviorCompileOnly.scala | 3 +-
.../persistence/typed/ManyRecoveriesSpec.scala | 3 +-
.../persistence/journal/inmem/InmemJournal.scala | 9 +-
.../persistence/AtLeastOnceDeliverySpec.scala | 6 +-
project/Dependencies.scala | 28 +-
project/Doc.scala | 3 +-
project/Paradox.scala | 9 +-
project/PekkoBuild.scala | 20 +-
project/PekkoDisciplinePlugin.scala | 53 +--
project/SbtMultiJvmPlugin.scala | 3 +-
project/StreamOperatorsIndexGenerator.scala | 3 +-
project/TestExtras.scala | 9 +-
project/build.properties | 2 +-
project/plugins.sbt | 8 +-
.../pekko/remote/routing/RemoteRandomSpec.scala | 3 +-
.../remote/routing/RemoteScatterGatherSpec.scala | 3 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 3 +-
.../pekko/remote/artery/ArteryTransport.scala | 4 +-
.../apache/pekko/remote/artery/Association.scala | 3 +-
.../pekko/remote/artery/EnvelopeBufferPool.scala | 6 +-
.../pekko/remote/artery/MessageDispatcher.scala | 3 +-
.../pekko/remote/artery/aeron/AeronSink.scala | 3 +-
.../artery/aeron/ArteryAeronUdpTransport.scala | 11 +-
.../remote/artery/compress/CompressionTable.scala | 3 +-
.../remote/artery/tcp/ArteryTcpTransport.scala | 11 +-
.../transport/AbstractTransportAdapter.scala | 3 +-
.../pekko/remote/AccrualFailureDetectorSpec.scala | 7 +-
.../pekko/remote/DeadlineFailureDetectorSpec.scala | 3 +-
.../pekko/remote/artery/ImmutableLongMapSpec.scala | 9 +-
.../remote/artery/OutboundIdleShutdownSpec.scala | 3 +-
.../pekko/remote/artery/RemoteWatcherSpec.scala | 3 +-
.../pekko/remote/artery/tcp/TcpFramingSpec.scala | 4 +-
.../pekko/remote/classic/RemoteWatcherSpec.scala | 3 +-
.../apache/pekko/stream/DslConsistencySpec.scala | 6 +-
.../pekko/stream/DslFactoriesConsistencySpec.scala | 9 +-
.../stream/impl/LinearTraversalBuilderSpec.scala | 3 +-
.../pekko/stream/impl/TraversalBuilderSpec.scala | 5 +-
.../pekko/stream/impl/fusing/InterpreterSpec.scala | 3 +-
.../impl/fusing/LifecycleInterpreterSpec.scala | 6 +-
.../pekko/stream/io/ByteStringParserSpec.scala | 3 +-
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 41 +-
.../stream/scaladsl/CancellationStrategySpec.scala | 3 +-
.../stream/scaladsl/FlowGroupedWithinSpec.scala | 3 +-
.../pekko/stream/scaladsl/FlowIteratorSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowOrElseSpec.scala | 3 +-
.../stream/scaladsl/FlowRecoverWithSpec.scala | 432 ++++++++++++++++++++-
.../apache/pekko/stream/scaladsl/RestartSpec.scala | 6 +-
.../pekko/stream/scaladsl/RetryFlowSpec.scala | 3 +-
.../apache/pekko/stream/scaladsl/SourceSpec.scala | 137 ++++++-
.../pekko/stream/javadsl/CollectionUtil.scala | 39 --
.../pekko/stream/javadsl/CollectionUtil.scala | 39 --
.../main/scala/org/apache/pekko/stream/Shape.scala | 3 +-
.../apache/pekko/stream/SystemMaterializer.scala | 9 +-
.../scala/org/apache/pekko/stream/impl/FanIn.scala | 3 +-
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 17 +-
.../apache/pekko/stream/impl/io/TcpStages.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Flow.scala | 10 +-
.../org/apache/pekko/stream/javadsl/Sink.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 25 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 8 +-
.../apache/pekko/stream/javadsl/SubSource.scala | 8 +-
.../org/apache/pekko/stream/javadsl/Tcp.scala | 9 +-
.../org/apache/pekko/stream/scaladsl/Flow.scala | 2 +
.../org/apache/pekko/stream/scaladsl/Source.scala | 18 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 3 +-
184 files changed, 1341 insertions(+), 701 deletions(-)
copy .github/workflows/{nightly-1.4-builds.yml => nightly-1.5-builds.yml} (86%)
copy .github/workflows/{publish-1.4-nightly.yml => publish-1.5-nightly.yml}
(87%)
delete mode 100644 .github/workflows/scala-steward.yml
delete mode 100644
stream/src/main/scala-2.13/org/apache/pekko/stream/javadsl/CollectionUtil.scala
delete mode 100644
stream/src/main/scala-3/org/apache/pekko/stream/javadsl/CollectionUtil.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
