You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by he...@apache.org on 2026/07/08 18:38:50 UTC
(pekko) branch asJavaStream updated (e5f889e2d5 -> eecb5931f5)
This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a change to branch asJavaStream
in repository https://gitbox.apache.org/repos/asf/pekko.git
omit e5f889e2d5 feat: Add asJavaStream to Sink
add 9b6797f3d8 add tests for ByteStrings with non-zero startIndex (#2158)
add 47e7e23f2d chore: make toAttributes a lazy val (#2157)
add c87b3cff72 Update sbt, scripted-plugin to 1.11.6 (#2167)
add 8d9450b19e chore: Add boolean parameter name when call registerForExecution (#2173)
add 7b96bb8385 chore: Remove ExecutorServiceFactoryProvider from ThreadPoolConfig (#2175)
add 458ceed37e feat: Add virtualize support for thread-pool-executor (#2169)
add 44d5b78cf2 chore(deps): bump sbt/setup-sbt from 1.1.12 to 1.1.13 (#2179)
add 91401ebca1 Add 1.2.x branch to binary compatibility checks (#2181)
add 7fb098985b chore: Remove ReentrantGuard (#2161)
add 4ef6400f6a Update netty-handler, netty-transport to 4.2.6.Final (#2184)
add 4405e736c1 Update typesafe:config to 1.4.5 (#2191)
add 38b52eab96 Update gson to 2.13.2 (#2190)
add a77b6f162c Update gson to 2.13.2 (#2190)
add e8f241dba6 Update sbt-license-report to 1.8.0 (#2189)
add 42c2b493cb chore: Remove japi.option method (#2193)
add f48ec1d425 update docs for calculateDelay (#2196)
add 0f6def662f chore: Make use of japi.funtion.* in Patterns (#2198)
add f2b677dfa0 remove scala 2.12 support (#1986)
add 4d7bc6899e chore: remove scala.compat.java8 in osgi (#2211)
add c0ffd72dec Update protobuf-java to 4.32.1 (#2216)
add 94ae86fa6f Update sbt-header to 5.11.0 (#2217)
add daf3458185 Use stdlib IntFunction to not allow throwing (#2200)
add db43bf4697 Update metrics-core, metrics-jvm to 4.2.37 (#2224)
add ee704f7e5a Update sbt-develocity to 1.4 (#2223)
add e66cda2899 remove some stray java version checks (#2227)
add 5acdace08c chore: Remove compat Future (#2212)
add 8c48393cd3 chore: Remove pekko.dispatch.ExecutionContexts.parasitic (#2208)
add 3969ae8276 chore: Remove serialversion-remover-plugin (#2204)
add 9b5e641246 feat: Add sneakyThrow for Java (#2218)
add 04f5fcd1b7 chore: Use Scala Option Converter (#2203)
add 875840d3b8 chore: Remove pekko.util.FutureConverters (#2207)
add 9b2853c730 chore: Use scala.jdk.DurationConverters (#2205)
add 8254acc0e8 chore: Remove ccompat.JavaConverters (#2234)
add d89f3ff6ab Update scalafmt version to 3.9.10 (#2225)
add 4d89553471 chore: Use scala.jdk.CollectionConverters (#2236)
add 870d4499cc chore: sort imports (#2235)
add 5657514b39 chore: Add revision to git ignore blame (#2240)
add 4f2434b650 chore: Drop @unused annotation from pekko (#2241)
add 1feb26f89e fix: drop fiddle_code (#2237)
add 3a67477afd remove unnecessary scalafix plugin (#2243)
add d555a86f6d remove unnecessary items from license (#2246)
add 343491bcdb remove unused script (#2247)
add 57812486e1 fix: drop vavr (#2248)
add a1ade992ff feat: Add Sink#count operator. (#2244)
add 0ddb7a2ec7 chore: Make val debug final (#2251)
add ff3bed8cdc remove stray ref to java 8 in build (#2252)
add 92ca0314c0 silence compiler warnings new in scala 2.13.17 (#2255)
add 183fda795f refactor compiler options (#2253)
add 2684a7fe44 chore(deps): bump VirtusLab/scala-cli-setup from 1.9.0 to 1.9.1 (#2258)
add 34285df046 Update ByteStringSpec.scala (#2257)
add 878d219f1f fix: run AsyncDnsResolverIntegrationSpec on Apple M series machines (#2249)
add 750bf235f1 chore: Fuse in and out handler for setupStage (#2259)
add 391b71a3d0 chore: Rewrite ClassContext with scala (#2260)
add a579679445 feat: Add Sink#source (#2250)
add a55a719c8e release notes for 1.2.1 (#2245)
add 91554a46db protect 1.3.x branch (#2264)
add 3cfe37f016 chore: Use array list for better performance in BroadcastHub (#2262)
add c5c6a5e4ed chore(deps): bump scacap/action-surefire-report from 1.9.0 to 1.9.1 (#2266)
add aec4fafa49 Update sbt-license-report to 1.9.0 (#2267)
add e3e01889c8 feat: Support setting starting number of virtual thread. (#2242)
add 78cfe25fe9 no need for separate Scala 2 and 3 ByteStrings (#2269)
add a02c62b1fd ByteString Indexof with from and to (#2271)
add cee1ec63df use Scala FunctionConverter (#2274)
add 295e15d144 add containsSlice tests (#2275)
add 84daa52649 set up CI for 1.3 branch (#2273)
add 81154573fd Support SWAR lookup in ByteString indexOf (#2148)
add 2c0375049b Update sbt-develocity to 1.4.1 (#2276)
add 6906820e69 JavaDSL TestKit - add shutdownActorSystem that takes Java Duration params (#2277)
add 6fdd2dffcb try to fix doc build issue (#2279)
add ff0e836028 Update sbt-jmh to 0.4.8 (#2281)
add 848bae73a1 Update agrona to 2.3.0 (#2280)
add 5757fa25bf Update junit-jupiter-engine to 5.14.0 (#2283)
add 42c1f44603 chore: Update Scala 2.13 version to 2.13.17 (#2284)
add bf3b350a7e jupiter junit 6 (#2287)
add 72949bbd77 add junit6 support (#2289)
add 56e8a80f67 Update JavaVersion.scala (#2290)
add 36ace8998c use LazyList (#2291)
add 0d36a6f928 Update converter references in CONTRIBUTING.md (#2293)
add a3a8cf32d3 try to remove unnecessary map calls (#2292)
add c76c63fb43 Update aeron-client, aeron-driver to 1.49.0 (#2295)
add 367ca277e7 Update logback-classic to 1.5.19 (#2294)
add bbb5c93984 chore(deps): bump sbt/setup-sbt from 1.1.13 to 1.1.14 (#2299)
add 49e4864446 Fix markdown links in distributed pub-sub documentation (#2298)
add 54d6b42756 Update README to remove Java 11 requirement (#2296)
add bb706ea442 Add 'message-driven' to project tags (#2304)
add 30a0046944 use UnsynchronizedByteArrayInputStream (#2300)
add 6f1cae6c86 Update sbt, scripted-plugin to 1.11.7 (#2308)
add d78b7c99cd Update sbt-source-dist to 0.1.13 (#2307)
add dc49fc6358 chore: fix up some GitHub Actions pins (#2310)
add bda5b0cf2e use indexOf to run ByteString contains check (#2309)
add c36dc85c8c Compute OSGi imports for Pekko packages dynamically #2312 (#2313)
add 71ff3ff9b5 chore: bump Scala version to 3.3.7 (#2104)
add 8bcc69691b chore: harden GHA (#2311)
add d5baeb5afb Update sbt-scalafix to 0.14.4 (#2318)
add e62592c4b4 specialized version of indexOfSlice (#2306)
add 4b2917faae Create ByteString_indexOfSlice_Benchmark.scala (#2325)
add 84a04638c5 chore(deps): bump coursier/cache-action from 6.4.7 to 6.4.8 (#2320)
add 5effa43ec8 Update netty-handler, netty-transport to 4.2.7.Final (#2328)
add 7a57d4222b Update protobuf-java to 4.33.0 (#2327)
add 005f574abb Update sbt-sbom to 0.5.0 (#2326)
add 87b7ae810d feat: Add Flow#onErrorContinue operator. (#2322)
add bd8865e02c chore: Update since version of Sink source and count (#2338)
add b9e4b3126f Update `@since` annotation in Sink.scala (#2339)
add d23bab48e7 feat: Add missing onErrorResume to SubFlow and SubSource (#2337)
add b66f0d3e0e regenerate protobuf classes (#2335)
add 569b1263f7 feat: Add more recover operators for java dsl. (#2336)
add 766d318831 revert recent aeron upgrade while we investigate test issue (#2331)
add 0e2eeb5c18 add some Bytestring tests (#2330)
add 3bb3291ab7 Revert manual disabling of sbt-license-report
add 1a8decd9a3 Support Jackson 3 (#2348)
add 66fed4bd2d remove pekko.ssl-config (#2359)
add 36d8a1b7b7 feat: Add doOnFirst operator (#2363)
add 96e2e8374d add extra test coverage to JsonFraming code (#2362)
add 09cf48860d Fix typos in Markdown and Scala files (#2366)
add 31ece7bfcc chore: Add missing scala doc for watchTermination operator. (#2368)
add 07f7f679ee Fix spelling in Markdown and Scala files (#2369)
add a7b9dc452c Fix typos in Java, Markdown and Scala files (#2371)
add dbdbe03a13 fix close in cancel for statefulMap (#2365)
add fcdd35a897 feat: Add doOnCancel operator. (#2375)
add 145a816292 chore: Remove unnecessary watchTermination parentheses (#2378)
add c4e0ec8bce Replaying a replicated event sourced actor from snapshot caused bug (#2372)
add e13f56a7c0 fix config name in distributed-data doc (#2381)
add a4f30005fa Update logback-classic to 1.5.20 (#2383)
add 5f511f8656 Update scalafmt-core to 3.10.1 (#2384)
add dcb5f344cd chore: fix FlowDoOnCancelSpec (#2386)
add 6a185b6825 fix: Update statefulMap scaladoc and tests (#2385)
add 78693c286b chore: document add-opens flags (#2391)
add 1e2075c82e chore: fix typo in stream-customize.md (#2392)
add 8c9e1ac5ed add actor-typed Java DSL AbstractOnMessageBehavior (#2379)
add 8a619dc722 chore: Remove the deprecated overloaded aggregateWithBoundary method (#2146)
add 7830a1cb10 fix: emitting DeletedDurableState for deleted objects (#2397)
add 8182052f3d chore: Migrate to Strings.CI.contains (#2400)
add 46a9389d5a Rename gunzip to gzipDecompress
add f24b072f64 Remove deprecated gUnzip function
add d0be463fa1 chore: opt serializerFor (#2395)
add 21a94e3182 chore: document protobuf-java/protoc version relationship (#2411)
add c37cbc6192 feat: Add fromOption operator (#2413)
add be7b6d40cb Update jackson-core to 2.20.1 (#2417)
add 62fb8fb200 Update aeron-client, aeron-driver to 1.48.7 (#2418)
add b6be9df5aa Update sbt-scalafmt to 2.5.6 (#2420)
add c3e1793b70 Update junit-jupiter-engine to 6.0.1 (#2419)
add a08b52132f feat: Add mapOption operator (#2414)
add 2c2daa88a1 feat: Add fromArray to Source scaladsl (#2424)
add 7fa5559394 chore: sortImports (#2425)
add c624e2cf4c chore: ignore sort imports commit (#2426)
add 2dc8960074 Change Source.fromArray to Source.apply
add 71b588e80f change propagate-harmless-quarantine-events default to off (#2430)
add 5321efedb7 persistence-typed: custom stash support (#2433)
add b93ef0bc31 update doc for write-response-global-order (#2437)
add f86d79ba3c Compare required RC and M versions if present (#2441)
add ea0dcc866b chore: Deprecate stream testkit's prob methods (#2439)
add 0f299aff19 Update jackson-module-scala to 3.0.2 (#2449)
add 4cb69977d7 Update jackson-dataformat-cbor to 3.0.2 (#2448)
add 15be1f0b14 Update jackson-core, jackson-databind to 3.0.2 (#2447)
add b4e216520d Update agrona to 2.3.1 (#2446)
add f76f652a4e Update commons-io to 2.21.0 (#2445)
add 7aa5457b36 Add tools.jackson dependencies to scala-steward config (#2454)
add d2b7cdb208 chore: Fix typo of OptionVal's scaladoc (#2451)
add e695cc9988 chore: Remove stream testkit's prob methods (#2440)
add 51392022ab feat: Add effectful asking support in typed BehaviorTestKit (#2450)
add 2f503e5cc5 update doc and tests that still refer to java 8 (#2458)
add c3c549dda6 Update agrona to 2.3.2 (#2461)
add 82692c8646 feat: Add asking support to BehaviorTestKit (#2453)
add 523c05f7f6 feat: Add unpersistent versions of persistent behaviors (#2456)
add 6d5996277c Add OptionalUtil to Java util
add e251356ad9 Update lmdbjava to 0.9.2 (#2462)
add 06671fda10 remove outdated jdk9 test setup (#2466)
add 274d704d6b Make automatic flushing of compression configurable
add 2d5ce35516 rework reactivestreams docs (#2468)
add f0db8f0c33 feat: Add Source#items (#2429)
add 524f82b66a fix: poll bind via UDP before starting tests (#2475)
add 16ca91cd8d ci: stage release candidate sources and jars (#2314)
add 361122687f chore(deps): bump sbt/setup-sbt from 1.1.13 to 1.1.14 (#2478)
add d52aca20bc Fix AsyncWriteJournalResponseOrderSpec with global dispatcher (#2477)
add ccd1a51a79 Change default persistence plugin-dispatcher (#2482)
add a6e3987668 Revert "Update lmdbjava to 0.9.2 (#2462)" (#2483)
add 31410914c9 small link issue in doc links to files (#2481)
add 7e514eb082 chore: don't auto-update agrona (#2471)
add 6f78bdb408 Update Scala and Java API URLs in link validator (#2488)
add 97d900327f replace broken link to Ben Christensen talk (#2489)
add d60fa79a58 Update OnMessageIntroTest.java (#2491)
add 9cab31bf55 make Java sample more modern by using sealed and record (#2493)
add 564b220239 some nightly tests with Java 25 (#1887)
add 1e1bc3ab73 Fix formatting of a URL in link-validator.conf (#2496)
add 0859d4ec62 Add OpenJDK 25 to supported JDK versions (#2495)
add 6d7d2d2794 rename UnpersistentBehavior as PersistenceProbeBehavior (#2494)
add d5ee8a63e3 feat: Add close method on ActorSystem (#2486)
add 25adde21a6 Update protobuf-java to 4.33.1 (#2504)
add c6684402da Update aeron-client, aeron-driver to 1.48.9 (#2505)
add 58029331e2 Update docker-java-core, ... to 3.7.0 (#2503)
add db9bf521dc Update logback-classic to 1.5.21 (#2502)
add 9560d2b132 test pekko 1.3 with java 25 (#2507)
add e42ba37224 handle build issue in OSGi build code (#2511)
add 39276c9221 chore: bump Scala to 2.13.18 (#2515)
add 29b7d22e29 Use duration converters for close()
add 8534c91383 Release notes for 1.3.0 (#2500)
add 4f385ab3d4 Update aeron-client, aeron-driver to 1.48.10 (#2524)
add 78fb486eea Update package documentation from Akka to Pekko (#2526)
add 8ee3f59325 chore(deps): bump actions/checkout from 5 to 6 (#2522)
add e3800f1c2c fix: stage releases from CI (#2529)
add fd5e8c963d feat: add trusted Automated Release Signing key (#2530)
add c3d06b0f0c chore(deps): bump actions/checkout from 5.0.1 to 6.0.0 (#2531)
add ebf50b8a21 feat: release vote email template (#2533)
add 00b44f3784 chore(deps): bump scala-steward-org/scala-steward-action (#2534)
add 99838f4636 switch to at.yawk.lz4:lz4-java due to CVE‐2025‐12183 (#2537)
add 9ed4003fa2 chore(deps): bump coursier/setup-action from 1.3.9 to 2.0.0 (#2535)
add f92e6ee4ef chore(deps): bump actions/checkout from 6.0.0 to 6.0.1 (#2540)
add 2d883653e9 protect 1.4.x branch and add CI job (#2538)
add b430398c47 chore: use ATR syntax for the vote end (#2543)
add d5bd449fed Add license header to mark-subsource-and-subflow-final excludes (#2542)
add 22e985e7a2 add CI job to publish 1.4 snapshots (#2541)
add abe9c6ec0f chore: test Scala 3 with `validatePullRequest` (#2544)
add d12860d503 Update lz4-java to 1.10.0 (#2546)
add acc9a80287 Update jackson-core to 3.0.3 (#2548)
add 4e6dddd07d Update scalafmt-core to 3.10.2
add 747131b9b0 Reformat with scalafmt 3.10.2
add 02145fcaf9 Add 'Reformat with scalafmt 3.10.2' to .git-blame-ignore-revs
add effb78829b Update lz4-java to 1.10.1 (#2552)
add d5f7d35a4d Update Scala API links to version 2.13.18 (#2551)
add 80faf8bb31 Update protobuf-java to 4.33.2 (#2557)
add a536fe38ed chore: Optimize Source.from iterable. (#2556)
add 56de5a10cf Release notes for 2.0.0-M1 (#2532)
add a869875329 add Source.apply that is optimised for Seq (#2562)
add 92f74b5044 chore(deps): bump scalacenter/sbt-dependency-submission (#2564)
add 22ce39e3a5 dependabot: update GitHub Actions only weekly (#2565)
add f7531ca69d docs: document the Agrona update may need `--add-opens` (#2566)
add 2968fc699e chore: only run link validator weekly (#2571)
add 509b18e200 add job to publish 2.0 docs and add note about agrona (#2567)
add 7c1af3d783 docs: build 2.x docs on Java 17 (#2572)
add 63d65378c8 release notes for 1.4.0 (#2549)
add e5ccc2e70f Update netty-handler, netty-transport to 4.2.8.Final (#2578)
add 41d0a831c5 Update sbt-develocity to 1.4.2 (#2577)
add 3e2fe81bff Update sbt-pekko-build to 0.4.7 (#2576)
add f6f9f00849 Update logback-classic to 1.5.22 (#2575)
add f62c66c129 Add required status checks for 1.5.x branch (#2580)
add 2ecc64c11f Update sbt-boilerplate to 0.8.0 (#2581)
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 1462ccd18b chore: Remove Source#future in javadsl (#2554)
add 7895473c8a chore(deps): bump sbt/setup-sbt from 1.1.18 to 1.1.19 (#2717)
add 66d7dc1946 Add Sink.eagerFutureSink to avoid NeverMaterializedException on empty streams (#2684)
add 9950b4aa67 Fix Java 25 stream test timeout failures (#2573) (#2728)
add 722b195e4d Fix Java unchecked warnings in stream testkit fluent API (#2625) (#2725)
add 73668deae9 Improve subscriber timeout error: use SubscriptionTimeoutException instead of AbruptTerminationException (#2645) (#2727)
add 566a3470f7 fix(stream): Source.combine single source with type-transforming fan-in strategies (#2723) (#2726)
add 32b265eaa0 switch some tests over to using junit-jupiter naming (#2729)
add ed4f49ef44 Include roundtrip latency and seq nr in heartbeat debug log (#2736)
add bc2d11cafe Release lease on shard stop (#2738)
add 50a2d6e4d5 Harden some specs (#2737)
add 13ec04c58e fix `@since` on new classes (#2732)
add 3e5209a372 remove stray ) in test pids (#2739)
add 867907c5a8 Update sbt, scripted-plugin to 1.12.6 (#2744)
add 15aeee6df9 Port CRDT key expiry from akka-core #31721 (#2733)
add d881e6a0f5 Auto-select SRV lookup for the name lookup if entry looks like a srv name (#2745)
add 0d017f1fce Add more clarification around deleting snapshots (#2741)
add f193fddf93 Optimize PropsAdapter + add test coverage (#2743)
add 608cbc98eb add test for groupBy not throwing tooManySubstreamsOpenException on closed substream (#2742)
add d0c8d0b302 Add FlowMapAsyncPartitionedSpec tests ported from akka/akka-core#31582 and akka/akka-core#31882 (#2747)
add 9ecd452771 chore: safer EventEnvelope.toString (#2751)
add e29c133a47 Port akka-core optimizations for typed actor context and system adapter (#2750)
add ef00073439 ddata: Add wildcard prefix subscriptions to Replicator (#2735)
add 6768ffe737 ShardedDaemonProcess: throttle keep-alive messages and limit to subset of nodes (#2734)
add ec27d6dd8c feat: Migrate all Java unit tests from JUnit 4 to JUnit 5 (Jupiter) (#2724)
add 0cd7a7dbe9 Update jupiter-interface, ... to 0.17.1 (#2756)
add 4f1bbe2ee2 deprecate Junit5 named classes (#2759)
add 88c2e99abf Update CONTRIBUTING.md with branch and license details (#2761)
add bac4192b1e Port akka-core#31753: Run DurableStateBehavior delete effect asynchronously like persist (#2752)
add 95ada404aa Update jupiter-interface, ... to 0.18.0 (#2764)
add 6e4f905856 Update docker-java-core, ... to 3.7.1 (#2763)
add c2a969af47 Port akka-core#31777: O(1) mandatory attribute lookup via map index (#2758)
add 1c633dae0b actor-typed: Fix ProducerController crash on restart (#2762)
add 98ed377601 Use ClusterShuttingDown in ddata Replicator (#2765)
add ab12a8f5ec Port akka-core#31834: Add ScheduledClock to reduce nanoTime overhead in recency-based passivation (#2766)
add cd6987c507 chore: fix flasky test in MetricsBasedResizerSpec (#2769)
add 4463da8420 Port akka-core#31784: Add only-one-snapshot optimization for retention strategies (#2767)
add dc804388af refactor: finalize preRestart method in AbstractActor and add stash support trait (#2768)
add d5d5a2d4bd Update Ratpack link to point to GitHub (#2770)
add c81134acb6 Update jackson-core to 2.21.2 (#2771)
add d61a7f9f36 Update protobuf-java to 4.34.1 (#2772)
add 47020e89d0 chore(deps): bump coursier/setup-action from 2.0.3 to 3.0.0 (#2773)
add 3a4246664c chore(deps): bump coursier/cache-action from 8.0.1 to 8.1.0 (#2774)
add 467ff8d492 chore(deps): bump sbt/setup-sbt from 1.1.19 to 1.1.20 (#2775)
add 4e8f81908c [AKKA-31844] dynamic scaling of ShardedDaemonProcess instances (#2755)
add a293c8d4b9 Fix scaladoc links in actor APIs (#2780)
add f7cb66044d Port akka-core#31859: Improve StopShards coordinator command (#2783)
add 550ea4bde5 Disable ClusterShardingHealthCheck after configured duration post member-up (#2785)
add 528507cf85 Update sbt, scripted-plugin to 1.12.7 (#2787)
add 9dde7e0e25 set pekko.remote.classic.netty.tcp.port = 0 (#2788)
add 2192edd3a0 Update netty-handler, netty-transport to 4.2.12.Final (#2790)
add d8be36c3b2 Update sbt, scripted-plugin to 1.12.8 (#2791)
add 3a444a5c08 Update biz.aQute.bndlib to 7.2.3 (#2789)
add 195cba7187 RememberEntity throttling per region instead of per shard (#2786)
add 6f8288510e Fix erlang.org link and typo in message delivery docs (#2800)
add 0606b921c7 Harden EventSourcedBehaviorRetentionSpec (#2794)
add f1a36ba76b Add StatusReply.fromTry and fromTryKeepException factory methods (#2796)
add c9713f0899 Improve error message for actorOf on typed ActorSystem (#2798)
add 1d35cccb11 Improve DData remember entities logging and consistency (#2799)
add 491c9550f7 Handle unexpected stop of TLS actor gracefully (#2801)
add 7fef63392e Fix EventSourcedBehaviorStashSpec flaky failures (#2804)
add 4c468a103b Add filtered and source fields to typed EventEnvelope (#2807)
add 3e0d18b017 Add @since 2.0.0 annotations to StatusReply.fromTry methods (#2810)
add 8a5bcd59dd Fix typo: "pre-build" → "pre-built" in StatusReply Scaladoc (#2809)
add a5fbcfbb30 Update GroupBy doc: use idiomatic groupBy key function (#2795)
add 307a6db900 Improve StatusReply Scaladoc: clarify serialization implications (#2811)
add 2e33ec5883 Align groupBy with scala version (#2816)
add 33f21f8ec5 Rename PersistentBehaviour to EventSourcedBehavior (#2818)
add d8bde17a0a upgrade scalatestplus jars (#2793)
add 3c95ddb4da Support for external transport of replicated events (#2808)
add e8b99aa04a Use American English spelling of "behavior" everywhere (#2820)
add 037b88ad29 Add StatusReply.fromCallable Java API for Try-like error handling (#2812)
add 01788cfecb Fix flaky PersistentActorRecoveryTimeoutSpec under CI load (#2817) (#2819)
add 5addd96f70 Fix stream IO dispatcher test failures (#2806)
add 9f8d87dc8e Update jackson-core to 3.1.1 (#2823)
add cd46003419 Update lmdbjava to 0.9.3 (#2813)
add 2c6cdec69e Update scalatest to 3.2.20 (#2792)
add 2c12c247cc Generate protobuf classes with 34.1 (#2822)
add ffeb0de4fd chore(deps): bump sbt/setup-sbt from 1.1.20 to 1.1.22 (#2825)
add d256b765cb Stabilize flaky tests on Java 25 (#2821)
add d548313a4b Add fine-grained stream error logging control (#2805)
add 292e4cf665 Fix EventSourcedBehaviorRetentionSpec non-determinism (#2803)
add 741e8fc120 no need to run every parallelism value (#2829)
add 1c8ceb8cd3 release notes for 1.5.0 (#2753)
add 49e74d32ab Update sbt-java-formatter to 0.11.0 (#2835)
add 38e7217727 Only one retention cycle in progress at a time (#2797)
add de4d91951d get rid of scala dependent versions of ScalaBatchable (#2837)
add 16de1600e3 use swar methods in a few more places (#2839)
add 3fb282fb3b chore(deps): bump coursier/cache-action from 8.0.1 to 8.1.0 (#2843)
add cde574aef3 chore(deps): bump jrouly/scalafmt-native-action from 4 to 5 (#2841)
add abdc2d2b85 chore(deps): bump sbt/setup-sbt from 1.1.19 to 1.1.22 (#2842)
add 994c72dd63 Remove non-deterministic SnapshotSerializeSpec test case (#2802)
add e4d65c7eb6 Update sbt, scripted-plugin to 1.12.9 (#2849)
add f193ec111e move readLong, readInt, readShort from ByteStringParser to ByteString so they can be optimized (#2847)
add f207a1761f cache bytestring hashcode (#2836)
add 2b0f6b8214 add jspecify nullable annotations on streams Java DSL (#2617)
add 7b4db77ca0 protect 1.6.x branch (#2851)
add 185f5097a9 Remove 1.5.x branch entry in dependabot.yml (#2852)
add 75e2780031 add jspecify to persistence libs (#2850)
add d576dc72e4 Update lz4-java to 1.11.0 (#2854)
add 973327be25 VarHandle multi-byte reads for ByteString lastIndexOf (#2838)
add 6f3de3b50a ByteString lastIndexOfSlice (#2855)
add c125c49d4a Update jackson-core to 3.1.2 (#2858)
add 50f8de0f7e Update scalafmt-core to 3.11.0 (#2857)
add f62b01eba3 Update sbt-scalafmt to 2.6.0 (#2856)
add be3a411f91 Remove implicit JUnit4 dependency from LogCapturingExtension (#2864) (#2865)
add 8e6501bd75 small optimisation on indexOf (#2863)
add 2f9917b2c5 Add ByteString.endsWith and expand startsWith test coverage (#2862)
add f636931e82 ByteString: fix bugs, type safety, and add performance improvements with tests (#2868)
add b23b4c7d7e fix: stabilise stream tests on JDK 25 nightly (timeout scaling, element counts) (#2869)
add 2c4fd6dd84 fix: correct comprehensive typos across entire project (83 files) (#2867)
add 1ab254acfb feat: make ForkJoinPool minimum-runnable configurable and improve pool documentation (#2871)
add 4973f2e6e9 chore(stream): remove internal FanOut Unzip (#2873)
add 1736d7f845 Fix early-exit bound in indexOf(elem, from, to) (#2876)
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 bdb0e87580 chore: keep nightly virtualize change minimal (#2882)
add a36d126509 Scale MapAsyncPartitionedSpec patience with test timefactor (#2884)
add 166e8df8f7 test: scale stream tck shutdown timeout (#2885)
add e72dd27236 fix: stabilise JDK 21+ / JDK 25 nightly test runs (#2889)
add c57fdcd983 Update SnapshotSerializerSpec.scala (#2891)
add 980d2bd844 fix: auto-tune ForkJoinPool minimum-runnable on JDK 21+ (#2890)
add 2a0faf2cda upgrade license headers (#2893)
add d2bc2c84d8 Update commons-io to 2.22.0 (#2892)
add bc78cd16d5 ByteStringBuilder.putInt/putLong: eliminate closure allocation via SWARUtil VarHandle writes (#2879)
add 88f338134c test(dispatch): pin minimum-runnable=-1 in ForkJoinExecutorConfiguratorSpec auto fixtures (#2894)
add b24d1045e1 fix: stabilize async DNS dispatchers under low minimum-runnable (#2895)
add b0f9779b47 test: fix flaky 'stop an underutilizationStreak when fully utilized' on JDK 25 (#2898)
add a257a9fca1 Fix copyToBuffer: guard negative return in ByteString1C.writeToBuffer (#2897)
add b96d35d79d fix: MapAsyncPartitioned drainQueue concurrent-modification race (#2899)
add c2c5557258 test: dilate timeouts in FlowPrefixAndTailSpec and FlowFlatMapConcatParallelismSpec (#2902)
add fab9594069 fix: stabilise JDK 25 nightly flakes (#2907)
add ff799125cd Update gson to 2.14.0 (#2908)
add d2c284e8d8 Update commons-codec to 1.22.0 (#2909)
add e0abd889ab fix: stabilise PersistentActorRecoveryTimeoutSpec (#2906)
add 4e2c1fe78d fix(stream): preserve abrupt fanout publisher shutdown signal (#2910)
add a57a0db001 fix: support virtualized dispatcher test assumptions (#2912)
add e762ed948f chore(deps): bump scacap/action-surefire-report from 1.9.1 to 1.10.0 (#2921)
add 51b52cc891 Fix nightly JDK 21 and 25 failures (#2922)
add fd5d87b35a Port akka-core PR #31889: fix coordinator role in cluster sharding (#2918)
add 579e2de947 Port akka-core PR #31906 and #31926: DnsResolutionActor and in-flight deduplication (#2919)
add d87353432b Port akka PRs #31891, #31892, #31893: tags in EventEnvelope, EventsByPersistenceIdTyped queries, withTaggerForState (#2920)
add 35a1e23b62 Enhance DurableStateStore TCK with OCC, serialization, and soft-delete tests (#2917)
add 58847e5c74 Update sbt, scripted-plugin to 1.12.10 (#2927)
add dd2533b78a Add AI agent contribution rules (#2911)
add 4176bf421c build: ignore local AI assistant workspace files (#2913)
add 6313843b3a Fix ByteString1C serialization to use SerializationProxy (#2929)
add 7f3b330705 Initialize DistributedData extension from ExternalShardAllocationStrategy eagerly (#2923)
add 02d61add26 Update jackson-core to 2.21.3 (#2930)
add 5c5e2aefb4 Update typesafe:config to 1.4.7 (#2931)
add 9c97136991 release notes for 1.6.0 (#2900)
add bfbc397a68 Update jackson-core to 3.1.3 (#2934)
add 2eef9c9ef5 Update sbt, scripted-plugin to 1.12.11 (#2933)
add 880b0075d6 fix: Fix virtualized dispatcher shutdown ordering (#2925)
add 15d716fa5c Update typesafe:config to 1.4.8 (#2935)
add 1d3c313dad Update netty-handler, netty-transport to 4.2.13.Final (#2936)
add 3071413202 aeron 1.50.4 (#2937)
add 3c78ad4eeb try to fix flaky RotatingProviderWithChangingKeysSpec (#2940)
add 967a270a04 MapAsyncPartitionedSpec: fix broken test on Java 25 (#2941)
add 66fb4c959f Document package requirements in AGENTS.md (#2944)
add 5a4f236db0 feat(stream): add TLS GraphStage engine (#2878)
add 8116ff7c5e feat: support SO_REUSEPORT socket option (#2915)
add 8675ef58e7 optimize ByteStrings startswith/endswith (#2896)
add 7965d95b0d Make ByteString.copyToBuffer(buffer, offset) public, add scaladoc and test coverage (#2946)
add 4900599a96 Stabilize JDK 25 virtualized stream tests (#2945)
add 198f936f29 Support ActorSystem/ClassicActorSystemProvider serializer constructors, improve error message (#2948)
add f2eb52af1d feat: Make it possible to define appVersion later (#2947)
add 973446d1c7 Optimize stream boundary event allocation (#2916)
add ebddbc2112 test: stabilize two flaky tests on JDK21+/virtualized nightly (#2949)
add f481c59dd9 perf: fast path getShort/Int/Long in MultiByteArrayIterator (#2952)
add 29d74ecb74 Optimize two-part ByteString concatenation (#2924)
add 4814873aca Update jupiter-interface, ... to 0.19.0 (#2951)
add 02a730ad28 chore: adjust snapshot retention warning (#2953)
add d4df90cf69 chore: add Java external shard allocation factory (#2954)
add e9b96ad44c cherry pick some doc fixes (#2956)
add 7ec121dd07 docs: document remoting certificate rotation (#2957)
add 364d7c6e70 docs: fix remoting incompatible change sentence (#2959)
add 93fec3e333 fix: serialize async DNS request id generation (#2958)
add b13d68f622 refactor: inline onEvent into MergeHub.tryProcessNext (#2901)
add 52747cdfee fix: harden async DNS request id handling (#2960)
add 9ae3c85af4 docs: document serializer constructor alternatives (#2962)
add 1e25aa89a8 perf(stream): reduce source construction overhead (#2914)
add ce82186c82 fix some stray refs to Akka classes and some uses of 'an' (#2963)
add da7787058e Update stage-release-candidate.yml (#2965)
add 5127105af4 chore(deps): bump scacap/action-surefire-report from 1.10.0 to 1.12.0 (#2967)
add c6e9a2e593 Update sbt-scalafmt to 2.6.1 (#2968)
add 1be23c7306 Update scalafmt-core to 3.11.1 (#2969)
add 61b1e4c283 Update jul-to-slf4j, log4j-over-slf4j, ... to 2.0.18 (#2970)
add 8c5d40d262 release notes for 2.0.0-M2 (#2964)
add fd5b64e601 remove revision param as it does not apply to this method (#2971)
add 83b1b31604 fix javadoc durable state deleteobject (#2972)
add 5e04084871 docs: forbid Co-authored-by and AI-assistant trailers (#2974)
add 25ed2d6a98 protect 1.7.x and setup ci (#2976)
add dbab131e9f chore(deps): bump scalacenter/sbt-dependency-submission (#2980)
add 4f20b47369 chore(deps): bump coursier/cache-action from 8.1.0 to 8.1.1 (#2979)
add 7429728805 optimize: FlattenMerge avoids substream materialization for value-presented sources (#2977)
add f6707d44f3 Update junit-platform-launcher to 6.1.0 (#2984)
add ccbef5b0da Update junit-jupiter-engine to 6.1.0 (#2983)
add 8044f69b30 Update protobuf-java to 4.35.0 (#2982)
add 415c4ae760 optimize: extend internalConcat dispatch for value-presented sources (#2978)
add b95809da0a Fuse restInHandler into GraphStageLogic in Intersperse (#2981)
add 956d478919 test: fix InterpreterBenchmark so it produces trustworthy numbers (#2985)
add a5058437af optimize: skip afterStageHasRun no-op finalize check in GraphInterpreter chase hot path (#2986)
add a6fb3ab0d5 Update netty-handler, netty-transport to 4.2.14.Final (#2987)
add cc22e586d3 chore(deps): bump sbt/setup-sbt from 1.1.22 to 1.1.24 (#2966)
add ef5bfa6c59 chore(deps): bump sbt/setup-sbt from 1.1.23 to 1.1.24 (#2989)
add 02a95c9fda Operator docs: add description and example for StreamConverters.javaCollector (#2992)
add 0b775569bc docs: add AI licensing rules to AGENTS.md and CLAUDE.md (#2993)
add 39a03d7863 Bump metrics-core, metrics-jvm to 4.2.39 (#2995)
add e482f186cd test: shut down cluster test systems in reverse order (#2997)
add fc3561b1d9 test: avoid busy-spin in stream stress tests (#2996)
add 97a92c214a test: relax SendQueue fuzzing deadlines (#2998)
add fcc541a71f test: clean up TLS edge streams after early cancellation (#3000)
add 900e1f65f1 test: ignore late identities while awaiting rotating-keys ping (#3001)
add 477149eefc test: await async alsoTo/wireTap side sink in context specs (#3006)
add 3fcbea76ae test: widen TCK actor-system-terminate phase timeout (#3005)
add 730252b352 test: scale TCK Await timeouts by pekko.test.timefactor (#3004)
add 6a52d0cfa1 fix: restore acquire semantics for AbstractNodeQueue node reads (#3007)
add c1910b2136 fix: restore volatile reads/writes downgraded by the VarHandle migration (#3008)
add fe8a81fb1d fix: complete MapAsyncPartitioned ordered stage after trailing resumed failures (#3009)
add c22bc2fbe9 Update jackson-core to 2.21.4 (#3011)
add 2a7010e777 Update logback-classic to 1.5.33 (#3010)
add 0729960f28 test: await eventual deletion in RemoveInternalClusterShardingDataSpec (#3013)
add ac88902422 test: widen HandshakeRetrySpec buffered-message timeout (#3012)
add 4d17e08c5b test: widen cluster shutdownAll await for aeron-udp drain on JDK 25 nightly (#3017)
add 61c3d960bf optimize: avoid Holder allocation in ordered mapAsync for already-completed futures (#3018)
add 59a2cc81af fix: await in-flight completion on partner termination in SinkRef (#3016)
add 22e38951a9 Update jackson-core to 3.1.4 (#3021)
add 575a79a3f7 docs: add MiMa fix requirement to CLAUDE.md and AGENTS.md (#3025)
add 42a4596780 fix: guard against int overflow in supervisor strategy and frequency sketch (#3022)
add 7c1d0a623d Fix sbt load warnings by excluding unused lint keys (#3029)
add bbb1e8efc9 chore(stream): remove dead ActorProcessor, ActorProcessorImpl, and ExposedPublisherReceive (#3027)
add 4e1508c38d chore(deps): bump sbt/setup-sbt from 1.1.24 to 1.2.1 (#3034)
add fbc05e26e8 chore(deps): bump scalacenter/sbt-dependency-submission (#3033)
add e04e721ab6 Replace Scala string interpolation in log calls with lazy {} placeholder format (#3032)
add a30df08865 2.0.0-M3 release notes (#3014)
add 27f6960dda ClusterShardingSettings: remove backward-compat passivation cruft (#3026)
add 3e7b5e9257 Update netty-handler, netty-transport to 4.2.15.Final (#3039)
add e012dd39ab Update logback-classic to 1.5.34 (#3038)
add 1dc09320aa fix: add missing space in StageActor PoisonPill/Kill warning message (#3040)
add 153c151950 fix: widen RemoteSendConsistencySpec await window to 30s (#3041)
add f6f988235b regenerate protobuf classes with protoc 4.35.0 (#3042)
add 70f6bbda56 Update biz.aQute.bndlib to 7.3.0 (#3044)
add 6f6fc8b7b5 Update jackson-core to 2.22.0 (#3045)
add 9a56d49ceb Update typesafe:config to 1.4.9 (#3046)
add 29dc5e8df3 chore: Rewrite to scala3 syntax (#3048)
add ca4b3aec02 test: retry temporary port bind in RemotingSpec lazy-connect test (#3015)
add 6371e5b4be chore(deps): bump actions/checkout from 6.0.2 to 6.0.3 (#3053)
add bf96f5afa6 fix: correct typos in comments, docs, and string literals across codebase (#3055)
add 0fc6120ddd Update Scala 3 version to 3.3.8 (#3056)
add 718c3f5675 Update protobuf-java to 4.35.1 (#3057)
add 52234c0199 Fix unresolvable scaladoc links to the ShardRegion actor #353 (#3064)
add bf54798054 Add -Yfuture-lazy-vals for Scala 3.3.x builds (#3059)
add 28d61c5368 perf: replace ArrayList consumer wheel with LongMap for O(1) keyed removal (#3063)
add 03ebaf59bb perf: optimize stream materializer wiring with HashMap and ArrayList replacements (#3062)
add 645b76fbc9 Runtime plugin configuration for DurableState (#3058)
add b3219211ee Update sbt, scripted-plugin to 1.12.12 (#3069)
add 83e45001d2 Update sbt-api-mappings to 3.0.3 (#3068)
add f253c25de6 Update sbt-scalafix to 0.14.7 (#3067)
add 3e578d8a75 chore: upgrade sbt-java-formatter to 0.12.0 (#3066)
add f42ab033ab Update jackson-core to 3.2.0 (#3054)
add 400354ee8f aeron 1.51.0 (#3070)
add ba4e950edb Optimize lazy stage actor dispatch (#3035)
add ee6965cd58 fix: Scala 3.8 syntax compat fixes and import cleanup (#3074)
add 6482aa1d9f refactor: rename Jdk9 sbt plugin to Jdk21 to reflect actual purpose (#3075)
add 8a09821cc5 Add TCK tests for replay bounds across a deletion gap (#3076)
add 51931817f6 Update sbt-mima-plugin to 1.1.6 (#3078)
add 4749eda97f refactor: replace private[this] with private and = _ with explicit defaults for Scala 3.8 (#3072)
add 3cdbc7c8bb fix: ClassTag context bound compat for Scala 3.8 cross-build (#3073)
add 7b6b7ed6c1 make one of the new persistence-tck journal tests optional (#3083)
add 005e242489 fix(actor-typed): discard stale ReceiveTimeout after cancelReceiveTimeout to avoid NPE (#3086)
add 1d75d4e852 docs: Licensing Rules 顶部增加新文件 header 强制流程提示 (#3087)
add 4d942a0ca7 use assertInstanceof (#3088)
add 0830f58d28 fix: correct various typos across pekko modules (#3084)
add baa1229037 refactor: modernize BlogPostEntity Java test code with Java 17 records (#3085)
add 41b142dd23 perf(stream): optimize Source.actorRef with direct-push fast path and message-only FunctionRef (#3091)
add 048c5f4a5a test: select the active FileSource actor in dispatcher checks (#3002)
add 3424402ec1 pin sbt version entry in .scala-steward.conf (#3115)
add d75bf95017 fix: keep lazy dispatch state on VarHandle (#3116)
add b61d9d0b5e chore(deps): bump actions/checkout from 6.0.3 to 7.0.0 (#3117)
add 3eb757c061 chore(deps): bump sbt/setup-sbt from 1.2.1 to 1.4.0 (#3118)
add 85bc2aa1d3 perf(stream): extract reportStageError out of GraphInterpreter.execute hot loop (#3119)
add e6d1533a72 Fix a few broken Scaladoc links reported by unidoc #353 (#3120)
add b09ee8b2f4 Update sbt-welcome to 0.6.0 (#3121)
add d1d2c1ef4c Update sbt, scripted-plugin to 1.12.13 (#3123)
add c0ed0aff7a Update sbt-sbom to 0.6.0 (#3122)
add f57cc814c7 fix(stream): log supervision Resume/Restart in MapAsync operators (#3124)
add f571b64f78 refactor: use RandomGenerator interface instead of java.util.Random (#3153)
add e1e2f2a4b1 refactor: use ProcessHandle.current().pid() instead of RuntimeMXBean hack (#3152)
add f60702a4de refactor: replace manual stream copy loops with transferTo/readAllBytes (#3146)
add fe5771080c refactor: use String.formatted() instead of String.format() (#3144)
add 6628442f16 fix: remove redundant Float cast in CountMinSketch pattern match (#3142)
add 71588172e8 refactor: use StackWalker for stack trace inspection in TestKitUtils (#3141)
add 52755c47c0 refactor: use ByteBuffer fluent API chains with JDK 9 covariant returns (#3139)
add 3ac83fbd31 fix(stream): prevent double materialization of SourceRef and SinkRef with clear error (#3114)
add 58a9bf0077 perf: use Arrays.copyOf/copyOfRange instead of manual new Array + arraycopy (#3150)
add 6ad445271c refactor: use StandardCharsets.UTF_8 with URLEncoder/URLDecoder (#3147)
add 0bbdbf78ec refactor: simplify Collections.unmodifiableSet(emptySet()) to Set.of() (#3138)
add acd4926ac1 refactor: use CompletableFuture.orTimeout in FutureTimeoutSupport (#3137)
add b7ba750296 refactor: replace sun.reflect.Reflection with StackWalker in Reflect (#3151)
add 22d44aa429 refactor: use Files.readString() in PemManagersProvider (#3143)
add 88320c6978 refactor: use HexFormat for hex encoding instead of manual formatting (#3145)
add 713ad01e16 perf: add Thread.onSpinWait() to CAS spin loops (#3149)
add d957aa9887 docs: update Scaladoc examples from Arrays.asList to List.of (#3140)
add cd980eac30 use decodeString(StandardCharsets.UTF_8) (#3155)
add 640e790be5 Fix comparing release against pre-release versions (#3154)
add 72c92cc678 fix: use Timers for finishConnect retry instead of raw scheduler callback (#3156)
add 1ba7efbe86 fix: initialize timer stage deadlines in preStart instead of at construction (#3111)
add f3654268e7 Preserve throttler tokens on failed writes (#3097)
add 61e165c23d use Locale.ROOT for toLowerCase/toUpperCase (#3159)
add 5b2f4b468b Ignore stale classic remoting ACKs #3126 (#3158)
add c532ea043b fix: delay unfoldResourceAsync close until pending read completes (#3157)
add 744dbd634f feat: replace CountMinSketch with FastFrequencySketch in Artery compression (#3023)
add 63d22b60fe Clean up stopped FSM transition listeners (#3096)
add 9afe0e9109 fix(artery): distribute ActorSelection messages across outbound lanes by target path (#3092)
add 14ed9a18b7 chore: add sbt-salad-days to reduce Scaladoc archive size (#3100)
add 44e2aaecae test: make InputStreamSource TCK publisher finite (#2999)
add 74b9ab2dec fix: harden EndpointReader against NonFatal dispatch errors and unwrap WrappedMessage in writer logs (#3166)
add 0a5529fda0 Update sbt-salad-days to 0.2.0 (#3171)
add 3757df0128 Update logback-classic to 1.5.35 (#3170)
add 07a346cc4b fix: validate full UniqueAddress in Artery system message ACK/NACK handling (#3175)
add 69e5216f42 fix: avoid double close in unfoldResource (#3172)
add 08ca126ca9 fix: improve TLS observability - handshake failure logging and fail-fast SSL init (#3165)
add 51d64ff1dd refactor: use pattern matching instanceof (Java 16+) (#3192)
add 9be70a423c refactor: apply misc Java 11-17 improvements (#3193)
add 96b716b6fb refactor: migrate switch statements to modern switch syntax (Java 14+) (#3191)
add b50f8a6991 refactor: migrate String.format to String.formatted (Java 15+) (#3190)
add 4c4d0b7665 refactor: replace .collect(Collectors.toList()) with .toList() (#3189)
add 78cd528313 refactor: migrate Collections.unmodifiable* to List.copyOf/Set.copyOf/Map.copyOf (Java 10+) (#3194)
add 2e944ef1bf Update logback-classic to 1.5.37 (#3196)
add 526cb8c6d6 deprecation (#3197)
add 612851ec4e fix: add supervision strategy support for batch costFn (#3184)
add a673f55e59 refactor: migrate Collections/Arrays.asList to Java 9+ collection factories (#3188)
add bf8adfb50e feat: add optional TLS hostname verification for classic remoting (#3164)
add 7becc119d3 fix(remote): eager SSLContext init for artery ConfigSSLEngineProvider fail-fast (#3200)
add 965b6b85c6 fix: ignore stale classic remoting reader ACKs (#3173)
add 0231702fd5 Remove fanout publisher sink wrapper (#3176)
add 22084da85c feat: add supervision strategy support for groupedWeightedWithin costFn (#3180)
add 036327de8b fix(remote): restore eager SSLContext init for classic remoting fail-fast (#3201)
add a626d6212a feat(stream): add withContext filtering and truncating operators (#3199)
add b1148ae256 fix code to use correct pekko.remote.classic.use-passive-connections name (#3207)
add 7328e559e0 test: stabilize mixed protocol netty ssl cluster join (#3203)
add fdbf6a4317 feat: add supervision strategy support for delayWith (#3182)
add 07cda18251 feat: add supervision strategy support for doOnFirst (#3179)
add e077d55cef feat: add supervision strategy support for throttle costCalculation (#3183)
add 99fe5f78a6 fix(remote): configure TLS resources for bind canonical tests (#3210)
add 0b9755a079 fix: add supervision strategy support for zipWith and zipWithN zipper functions (#3186)
add 1f8479bcfa feat: add supervision strategy support for groupedAdjacentBy/Weighted (#3181)
add a993c16083 fix: add supervision strategy support for aggregateWithBoundary callbacks (#3187)
add 9e5b807897 Update junit-jupiter-engine to 6.1.1 (#3260)
add 0874a04892 Update junit-platform-launcher to 6.1.1 (#3261)
add c0e9406bfd fix: expand Array arguments in MarkerLoggingAdapter log templates (#3263)
add 64e26c8e51 docs: Clarify retry attempts parameter (#3266)
add cfaec70e81 fix: replace broken scalafmt-native-action with coursier/setup-action (#3269)
add 84aa2b20e4 fix: add supervision strategy support for expand and extrapolate (#3185)
add cf6784b952 fix: return proper thread-safe Cancellable from StubbedActorContext.scheduleOnce (#3268)
add 26d8b60f19 feat(stream): add alsoTo overload with configurable cancellation propagation (#3127)
add 6287b9de07 Include exception type in StatusReply toString when not text (#3271)
add 5d1b67dedf docs: document preMaterialize error-propagation caveat (#3272)
add b9bd7d0f5a feat: add FilteredPayload placeholder for filtered journal events (#3275)
add 05b300dafb Port scalable fan-out persistence query abstraction from Akka (#3277)
add 26c5086c7c docs: how to write a custom Durable State store plugin (#3274)
add 5120ec6e48 docs: fix import order in state store plugin examples (#3278)
add ba462fb3af Update aeron-client, aeron-driver to 1.51.1 (#3280)
add 2e9734bee9 Fix ambiguous scaladoc overload links in persistence-typed #353 (#3281)
add 1a251f8510 Fix ambiguous scaladoc overload links in persistence module family #353 (#3282)
add 0516cd6f40 Update sbt-reproducible-builds to 0.33 (#3287)
add c4a28ba211 Update aeron-client, aeron-driver to 1.52.0 (#3286)
add 59dadc172c fix: suppress Java compilation warnings in actor, remote and docs modules (#3283)
add 8a3774add3 refactor: remove deprecated RepointableActorRef.isTerminated (since Akka 2.2) (#3289)
add 40ad2491c1 fix: fix javadoc warnings in actor module Java sources (#3284)
add b2ae2fafa7 fix: deliver stashed timer messages for UnboundedStash and UnrestrictedStash (#3264)
add 3b21abca49 fix(remote): resume classic remoting reader after failed handoff (#3205)
add bafe8a944d Fix timer current message for supervision #3265 (#3294)
add 535a5facc3 refactor: remove deprecated materializer settings APIs (#3293)
add 2610cda2af perf: batch async boundary elements (#3288)
add e520a7c642 test: cover async boundary failure draining (#3296)
add ceca95fe0d Close unregistered TCP channels on setup failure (#3273)
add 7ad07e692c refactor: remove deprecated SubstreamCancelStrategy and related splitWhen/splitAfter overloads (#3292)
add bbbf7b8bbe fix: fix scaladoc warnings (#3285)
add 79779612ab chore(deps): bump sbt/setup-sbt from 1.4.0 to 1.5.0 (#3298)
add 7f1a1b9140 refactor: replace deprecated `extends App` with explicit main method (#3299)
add ce8e081a0b fix: fix compilation warnings across Scala 2.13 and 3.3 cross-builds (#3297)
add 4ae53394ac feat: add Scala 3.8.4 cross-compilation target (#3295)
add d7369dbd1e Update lz4-java to 1.11.1 (#3302)
add 8353a4f16c chore: use StandardCharsets.UTF_8 (#3301)
add 339537eec3 fix: avoid NPE in outbound TCP stage when upstream finishes before connect (#3259)
add 17fb00e51e consistent-hashing shard allocation strategy (#3270)
add 44316a57f5 fix: release reference to initial interpreter shell after it is shut down (#3031)
add c522cfa626 Update netty-handler, netty-transport to 4.2.16.Final (#3307)
add c65e56f822 Update sbt-boilerplate to 0.8.1 (#3306)
add eecb5931f5 feat: Add asJavaStream to Sink
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 (e5f889e2d5)
\
N -- N -- N refs/heads/asJavaStream (eecb5931f5)
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:
.asf.yaml | 61 +
.git-blame-ignore-revs | 19 +
.github/dependabot.yml | 2 +-
.../resolve-scala-version.sh} | 38 +-
.github/workflows/binary-compatibility-checks.yml | 17 +-
.github/workflows/build-test-prValidation.yml | 45 +-
.github/workflows/dependency-graph.yml | 12 +-
.github/workflows/format.yml | 11 +-
.github/workflows/generate-doc-check.yml | 9 +-
.github/workflows/headers.yml | 8 +-
.github/workflows/link-validator.yml | 14 +-
.github/workflows/nightly-1.0-builds.yml | 21 +-
.github/workflows/nightly-1.1-builds.yml | 24 +-
.github/workflows/nightly-1.2-builds.yml | 28 +-
...ghtly-1.1-builds.yml => nightly-1.3-builds.yml} | 36 +-
...ghtly-1.1-builds.yml => nightly-1.4-builds.yml} | 36 +-
...ghtly-1.1-builds.yml => nightly-1.5-builds.yml} | 33 +-
...ghtly-1.1-builds.yml => nightly-1.6-builds.yml} | 33 +-
...ghtly-1.1-builds.yml => nightly-1.7-builds.yml} | 31 +-
.github/workflows/nightly-builds-aeron.yml | 7 +-
.github/workflows/nightly-builds.yml | 83 +-
.github/workflows/publish-1.0-docs.yml | 9 +-
.github/workflows/publish-1.0-nightly.yml | 9 +-
.github/workflows/publish-1.1-docs.yml | 9 +-
.github/workflows/publish-1.1-nightly.yml | 12 +-
.github/workflows/publish-1.2-docs.yml | 19 +-
.github/workflows/publish-1.2-nightly.yml | 12 +-
.../{publish-1.2-docs.yml => publish-1.3-docs.yml} | 35 +-
...ish-1.1-nightly.yml => publish-1.3-nightly.yml} | 17 +-
.../{publish-1.2-docs.yml => publish-1.4-docs.yml} | 35 +-
...ish-1.1-nightly.yml => publish-1.4-nightly.yml} | 15 +-
.../{publish-1.2-docs.yml => publish-1.5-docs.yml} | 35 +-
...ish-1.2-nightly.yml => publish-1.5-nightly.yml} | 17 +-
.../{publish-1.2-docs.yml => publish-1.6-docs.yml} | 35 +-
...ish-1.1-nightly.yml => publish-1.6-nightly.yml} | 17 +-
...ish-1.1-nightly.yml => publish-1.7-nightly.yml} | 15 +-
.../{publish-1.2-docs.yml => publish-2.0-docs.yml} | 38 +-
.github/workflows/publish-nightly.yml | 19 +-
.github/workflows/scala-steward.yml | 45 -
.github/workflows/scala3-build.yml | 77 -
.github/workflows/stage-release-candidate.yml | 353 +++
.github/workflows/timing-tests.yml | 9 +-
.gitignore | 13 +-
.scala-steward.conf | 12 +-
.scalafix.conf | 1 -
.scalafmt.conf | 15 +-
AGENTS.md | 227 ++
CLAUDE.md | 17 +
CONTRIBUTING.md | 86 +-
KEYS | 34 +
LICENSE | 25 +-
NOTICE | 14 +-
README.md | 4 +-
.../testkit/typed/annotations/JUnit5TestKit.java | 4 +
...JUnit5TestKit.java => JUnitJupiterTestKit.java} | 2 +-
.../add-ask-behavior-methods.excludes | 7 +-
.../renamed-methods.excludes | 4 +-
.../actor/testkit/typed/CapturedLogEvent.scala | 7 +-
.../apache/pekko/actor/testkit/typed/Effect.scala | 95 +-
.../pekko/actor/testkit/typed/LoggingEvent.scala | 9 +-
.../actor/testkit/typed/TestKitSettings.scala | 18 +-
.../testkit/typed/internal/ActorSystemStub.scala | 20 +-
.../typed/internal/BehaviorTestKitImpl.scala | 40 +-
.../testkit/typed/internal/CapturingAppender.scala | 2 +-
.../typed/internal/EffectfulActorContext.scala | 75 +-
.../actor/testkit/typed/internal/LogbackUtil.scala | 7 +-
.../typed/internal/LoggingTestKitImpl.scala | 16 +-
.../typed/internal/StubbedActorContext.scala | 29 +-
.../testkit/typed/internal/TestAppender.scala | 8 +-
.../testkit/typed/internal/TestInboxImpl.scala | 121 +-
.../testkit/typed/internal/TestKitUtils.scala | 6 +-
.../testkit/typed/internal/TestProbeImpl.scala | 38 +-
.../actor/testkit/typed/javadsl/ActorTestKit.scala | 27 +-
.../testkit/typed/javadsl/BehaviorTestKit.scala | 65 +-
.../actor/testkit/typed/javadsl/Effects.scala | 25 +-
.../typed/javadsl/JUnit5TestKitBuilder.scala | 8 +-
...lder.scala => JUnitJupiterTestKitBuilder.scala} | 15 +-
.../actor/testkit/typed/javadsl/LogCapturing.scala | 3 +-
.../typed/javadsl/LogCapturingExtension.scala | 17 +-
.../testkit/typed/javadsl/LoggingTestKit.scala | 10 +-
.../actor/testkit/typed/javadsl/ManualTime.scala | 12 +-
.../typed/javadsl/SerializationTestKit.scala | 2 +-
.../actor/testkit/typed/javadsl/TestInbox.scala | 88 +-
.../typed/javadsl/TestKitJUnit5Extension.scala | 6 +-
...on.scala => TestKitJUnitJupiterExtension.scala} | 11 +-
.../typed/javadsl/TestKitJunitResource.scala | 7 +-
.../actor/testkit/typed/javadsl/TestProbe.scala | 23 +-
.../testkit/typed/scaladsl/ActorTestKit.scala | 25 +-
.../testkit/typed/scaladsl/ActorTestKitBase.scala | 6 +-
.../testkit/typed/scaladsl/BehaviorTestKit.scala | 32 +-
.../actor/testkit/typed/scaladsl/Effects.scala | 15 +-
.../testkit/typed/scaladsl/LogCapturing.scala | 5 +-
.../testkit/typed/scaladsl/LoggingTestKit.scala | 6 +-
.../actor/testkit/typed/scaladsl/ManualTime.scala | 8 +-
.../typed/scaladsl/ScalaTestWithActorTestKit.scala | 13 +-
.../typed/scaladsl/SerializationTestKit.scala | 2 +-
.../actor/testkit/typed/scaladsl/TestInbox.scala | 96 +-
.../actor/testkit/typed/scaladsl/TestProbe.scala | 10 +-
.../typed/javadsl/AsyncTestingExampleTest.java | 28 +-
...ava => JUnitJupiterIntegrationExampleTest.java} | 21 +-
.../typed/javadsl/JunitIntegrationExampleTest.java | 21 +-
.../typed/javadsl/LogCapturingExampleTest.java | 18 +-
.../javadsl/LogCapturingExtensionExampleTest.java | 12 +-
.../typed/javadsl/ManualTimerExampleTest.java | 20 +-
.../typed/javadsl/SyncTestingExampleTest.java | 131 +-
.../testkit/typed/javadsl/TestConfigExample.java | 12 +-
...Test.java => ActorTestKitJUnitJupiterTest.java} | 19 +-
.../testkit/typed/javadsl/ActorTestKitTest.java | 16 +-
.../testkit/typed/javadsl/BehaviorTestKitTest.java | 237 +-
.../testkit/typed/javadsl/LoggingTestKitTest.java | 18 +-
.../actor/testkit/typed/javadsl/TestProbeTest.java | 41 +-
.../src/test/resources/application.conf | 2 +-
.../typed/scaladsl/SyncTestingExampleSpec.scala | 75 +-
.../testkit/typed/scaladsl/ActorTestKitSpec.scala | 15 +-
.../typed/scaladsl/BehaviorTestKitSpec.scala | 252 +-
.../actor/testkit/typed/scaladsl/GreeterMain.scala | 4 +
.../typed/scaladsl/JUnit5TestKitBuilderSpec.scala | 13 +-
....scala => JUnitJupiterTestKitBuilderSpec.scala} | 36 +-
.../typed/scaladsl/LoggingEventFilterSpec.scala | 5 +-
.../testkit/typed/scaladsl/TestAppenderSpec.scala | 5 +-
.../testkit/typed/scaladsl/TestProbeSpec.scala | 5 +-
actor-tests/src/test/bind/etc/db.0 | 12 -
actor-tests/src/test/bind/etc/db.127 | 13 -
actor-tests/src/test/bind/etc/db.255 | 12 -
actor-tests/src/test/bind/etc/db.bar.example | 2 +-
actor-tests/src/test/bind/etc/db.empty | 14 -
actor-tests/src/test/bind/etc/db.foo.test | 3 +-
actor-tests/src/test/bind/etc/db.local | 14 -
actor-tests/src/test/bind/etc/db.root | 90 -
actor-tests/src/test/bind/etc/named.conf | 11 -
.../src/test/bind/etc/named.conf.default-zones | 30 -
actor-tests/src/test/bind/etc/named.conf.local | 8 +-
actor-tests/src/test/bind/etc/named.conf.options | 23 +-
actor-tests/src/test/bind/etc/rndc.key | 4 -
actor-tests/src/test/bind/etc/zones.rfc1918 | 2 +-
.../pekko/actor/StashJavaAPITestUntypedActors.java | 4 +-
.../apache/pekko/actor/UntypedStashJavaAPI.java | 15 +-
.../actor/AbstractActorPreRestartFinalTest.java | 75 +
.../apache/pekko/actor/AbstractFSMActorTest.java | 18 +-
.../org/apache/pekko/actor/ActorCreationTest.java | 15 +-
.../org/apache/pekko/actor/ActorSelectionTest.java | 17 +-
.../org/apache/pekko/actor/ActorSystemTest.java | 32 +-
.../java/org/apache/pekko/actor/AddressTest.java | 7 +-
.../test/java/org/apache/pekko/actor/JavaAPI.java | 29 +-
.../java/org/apache/pekko/actor/JavaExtension.java | 16 +-
.../java/org/apache/pekko/actor/StashJavaAPI.java | 16 +-
.../apache/pekko/actor/StashJavaAPITestActors.java | 5 +-
.../pekko/actor/setup/ActorSystemSetupTest.java | 7 +-
.../pekko/dispatch/CompletionStagesTests.java | 36 +-
.../org/apache/pekko/dispatch/JavaFutureTests.java | 17 +-
.../java/org/apache/pekko/event/ActorWithMDC.java | 16 +-
.../org/apache/pekko/event/LoggingAdapterTest.java | 29 +-
.../org/apache/pekko/japi/FunctionLawTest.java | 29 +-
.../org/apache/pekko/japi/JavaAPITestBase.java | 7 +-
.../org/apache/pekko/japi/MatchBuilderTest.java | 34 +-
.../java/org/apache/pekko/japi/ThrowablesTest.java | 25 +-
.../org/apache/pekko/japi/pf/PFBuilderTest.java | 7 +-
.../apache/pekko/japi/pf/ReceiveBuilderTest.java | 46 +-
.../apache/pekko/pattern/CircuitBreakerTest.java | 27 +-
.../org/apache/pekko/pattern/PatternsTest.java | 112 +-
.../org/apache/pekko/pattern/StatusReplyTest.java | 37 +-
.../java/org/apache/pekko/util/ByteStringTest.java | 7 +-
.../org/apache/pekko/util/ConstantFunJavaTest.java | 14 +-
.../pekko/util/JavaConverterScala3InlineTest.java | 46 -
.../java/org/apache/pekko/util/JavaDuration.java | 7 +-
.../org/apache/pekko/util/TypedMultiMapSpec.scala | 1 +
.../org/apache/pekko/util/LineNumberSpec.scala | 4 +-
.../dispatch/ForkJoinPoolVirtualThreadSpec.scala | 170 +-
...pec.scala => ThreadPoolVirtualThreadSpec.scala} | 42 +-
.../dispatch/VirtualThreadPoolDispatcherSpec.scala | 6 +-
.../org/apache/pekko/PekkoExceptionSpec.scala | 6 +-
.../scala/org/apache/pekko/PekkoVersionSpec.scala | 15 +
.../actor/AbstractActorPreRestartFinalSpec.scala | 155 +
.../actor/ActorConfigurationVerificationSpec.scala | 4 +-
.../apache/pekko/actor/ActorCreationPerfSpec.scala | 6 +-
.../apache/pekko/actor/ActorLifeCycleSpec.scala | 4 +-
.../org/apache/pekko/actor/ActorMailboxSpec.scala | 13 +-
.../apache/pekko/actor/ActorSelectionSpec.scala | 4 +-
.../pekko/actor/ActorSystemDispatcherSpec.scala | 4 +-
.../org/apache/pekko/actor/ActorSystemSpec.scala | 50 +-
.../pekko/actor/ActorWithBoundedStashSpec.scala | 15 +-
.../apache/pekko/actor/ActorWithStashSpec.scala | 6 +-
.../pekko/actor/CoordinatedShutdownSpec.scala | 34 +-
.../pekko/actor/DeadLetterSupressionSpec.scala | 2 +-
.../pekko/actor/DeadLetterSuspensionSpec.scala | 2 +-
.../org/apache/pekko/actor/DeathWatchSpec.scala | 3 +-
.../org/apache/pekko/actor/DeployerSpec.scala | 6 +-
.../org/apache/pekko/actor/DynamicAccessSpec.scala | 2 +-
.../org/apache/pekko/actor/ExtensionSpec.scala | 19 +-
.../org/apache/pekko/actor/FSMActorSpec.scala | 11 +-
.../org/apache/pekko/actor/FSMTransitionSpec.scala | 28 +-
.../org/apache/pekko/actor/FunctionRefSpec.scala | 2 +-
.../pekko/actor/LocalActorRefProviderSpec.scala | 3 +-
.../org/apache/pekko/actor/PropsCreationSpec.scala | 7 +-
.../apache/pekko/actor/ProviderSelectionSpec.scala | 4 +-
.../apache/pekko/actor/ReceiveTimeoutSpec.scala | 3 +-
.../apache/pekko/actor/RelativeActorPathSpec.scala | 3 +-
.../apache/pekko/actor/RestartStrategySpec.scala | 5 +-
.../org/apache/pekko/actor/SchedulerSpec.scala | 35 +-
.../pekko/actor/SupervisorHierarchySpec.scala | 22 +-
.../apache/pekko/actor/SupervisorMiscSpec.scala | 5 +-
.../org/apache/pekko/actor/SupervisorSpec.scala | 50 +-
.../org/apache/pekko/actor/Ticket669Spec.scala | 6 +-
.../scala/org/apache/pekko/actor/TimerSpec.scala | 96 +
.../pekko/actor/dispatch/ActorModelSpec.scala | 11 +-
.../actor/dispatch/BalancingDispatcherSpec.scala | 3 +-
.../pekko/actor/dispatch/DispatcherActorSpec.scala | 5 +-
.../pekko/actor/dispatch/DispatchersSpec.scala | 41 +-
.../pekko/actor/dispatch/PinnedActorSpec.scala | 4 +-
.../pekko/actor/setup/ActorSystemSetupSpec.scala | 6 +-
.../scala/org/apache/pekko/config/ConfigSpec.scala | 7 +-
.../pekko/dispatch/DispatcherShutdownSpec.scala | 8 +-
.../pekko/dispatch/ExecutionContextSpec.scala | 33 +-
.../ForkJoinExecutorConfiguratorSpec.scala | 195 ++
.../dispatch/ForkJoinPoolStarvationSpec.scala | 4 +-
.../apache/pekko/dispatch/MailboxConfigSpec.scala | 16 +-
.../pekko/dispatch/PriorityDispatcherSpec.scala | 10 +-
.../dispatch/SameThreadExecutionContextSpec.scala | 19 +-
.../dispatch/StablePriorityDispatcherSpec.scala | 10 +-
.../org/apache/pekko/event/EventBusSpec.scala | 7 +-
.../org/apache/pekko/event/EventStreamSpec.scala | 4 +-
.../scala/org/apache/pekko/event/LoggerSpec.scala | 9 +-
.../apache/pekko/event/LoggingReceiveSpec.scala | 14 +-
.../org/apache/pekko/event/MarkerLoggingSpec.scala | 18 +
.../org/apache/pekko/io/InetSocketOptionSpec.scala | 82 +
.../org/apache/pekko/io/SimpleDnsCacheSpec.scala | 6 +-
.../org/apache/pekko/io/TcpConnectionSpec.scala | 48 +-
.../org/apache/pekko/io/TcpIntegrationSpec.scala | 29 +-
.../pekko/io/TcpIntegrationSpecSupport.scala | 4 +-
.../org/apache/pekko/io/TcpListenerSpec.scala | 2 +-
.../pekko/io/UdpConnectedIntegrationSpec.scala | 4 +-
.../org/apache/pekko/io/UdpIntegrationSpec.scala | 15 +
.../UnsynchronizedByteArrayInputStreamSpec.scala | 53 +
.../io/dns/AsyncDnsResolverIntegrationSpec.scala | 12 +-
.../org/apache/pekko/io/dns/DnsSettingsSpec.scala | 4 +-
.../apache/pekko/io/dns/DockerBindDnsService.scala | 57 +-
.../io/dns/internal/AsyncDnsResolverSpec.scala | 167 +-
.../pekko/io/dns/internal/DnsClientSpec.scala | 57 +-
.../apache/pekko/io/dns/internal/MessageSpec.scala | 6 +-
.../scala/org/apache/pekko/pattern/AskSpec.scala | 6 +-
.../pattern/BackoffOnRestartSupervisorSpec.scala | 3 +-
.../pekko/pattern/BackoffSupervisorSpec.scala | 6 +-
.../apache/pekko/pattern/CircuitBreakerSpec.scala | 1 +
.../pekko/pattern/CircuitBreakerStressSpec.scala | 2 +-
.../org/apache/pekko/pattern/PatternSpec.scala | 1 +
.../scala/org/apache/pekko/pattern/RetrySpec.scala | 41 +-
.../org/apache/pekko/pattern/StatusReplySpec.scala | 77 +-
.../org/apache/pekko/routing/BalancingSpec.scala | 15 +-
.../pekko/routing/ConfiguredLocalRoutingSpec.scala | 6 +-
.../pekko/routing/MetricsBasedResizerSpec.scala | 17 +-
.../org/apache/pekko/routing/ResizerSpec.scala | 4 +-
.../org/apache/pekko/routing/RoutingSpec.scala | 4 +-
.../routing/ScatterGatherFirstCompletedSpec.scala | 4 +-
.../pekko/serialization/AsyncSerializeSpec.scala | 5 +-
.../PrimitivesSerializationSpec.scala | 38 +-
.../serialization/SerializationSetupSpec.scala | 6 +-
.../apache/pekko/serialization/SerializeSpec.scala | 95 +-
.../testkit/CallingThreadDispatcherModelSpec.scala | 4 +-
.../pekko/util/BoundedBlockingQueueSpec.scala | 16 +-
.../org/apache/pekko/util/ByteIteratorSpec.scala | 47 +-
.../util/ByteStringBuilderScala213PlusSpec.scala | 0
.../pekko/util/ByteStringInitializationSpec.scala | 4 +-
.../pekko/util/ByteStringInputStreamSpec.scala | 4 +-
.../org/apache/pekko/util/ByteStringSpec.scala | 1924 +++++++++++-
.../org/apache/pekko/util/FrequencyListSpec.scala | 17 +-
.../apache/pekko/util/FrequencySketchSpec.scala | 46 +-
.../scala/org/apache/pekko/util/IndexSpec.scala | 6 +-
.../org/apache/pekko/util/MessageBufferSpec.scala | 4 +-
.../org/apache/pekko/util/RecencyListSpec.scala | 19 +-
.../scala/org/apache/pekko/util/ReflectSpec.scala | 33 +-
.../scala/org/apache/pekko/util/SWARUtilSpec.scala | 284 ++
.../org/apache/pekko/util/Scala212CompatTest.scala | 78 -
.../org/apache/pekko/util/ScheduledClockSpec.scala | 76 +
.../pekko/util/SegmentedRecencyListSpec.scala | 17 +-
.../scala/org/apache/pekko/util/TestClock.scala | 30 +
.../scala/org/apache/pekko/util/VersionSpec.scala | 1 +
.../org/apache/pekko/util/WildcardIndexSpec.scala | 6 +-
.../jdocs/org/apache/pekko/typed/Aggregator.java | 1 +
.../org/apache/pekko/typed/AggregatorTest.java | 105 +-
.../org/apache/pekko/typed/BubblingSample.java | 22 +-
.../org/apache/pekko/typed/BubblingSampleTest.java | 32 +-
.../jdocs/org/apache/pekko/typed/FSMDocTest.java | 2 +-
.../apache/pekko/typed/GracefulStopDocTest.java | 2 +
.../InteractionPatternsAskWithStatusTest.java | 23 +-
.../pekko/typed/InteractionPatternsTest.java | 281 +-
.../jdocs/org/apache/pekko/typed/IntroTest.java | 10 +
.../org/apache/pekko/typed/LoggingDocExamples.java | 3 +
.../org/apache/pekko/typed/MailboxDocTest.java | 31 +-
.../jdocs/org/apache/pekko/typed/OOIntroTest.java | 5 +
.../{OOIntroTest.java => OnMessageIntroTest.java} | 206 +-
.../jdocs/org/apache/pekko/typed/RouterTest.java | 17 +-
.../apache/pekko/typed/SpawnProtocolDocTest.java | 1 +
.../org/apache/pekko/typed/StashDocSample.java | 44 +-
.../jdocs/org/apache/pekko/typed/StashDocTest.java | 21 +-
.../apache/pekko/typed/StyleGuideDocExamples.java | 211 +-
.../jdocs/org/apache/pekko/typed/TailChopping.java | 1 +
.../coexistence/ClassicWatchingTypedTest.java | 16 +-
.../coexistence/TypedWatchingClassicTest.java | 5 +-
.../pekko/typed/fromclassic/TypedSample.java | 28 +-
.../apache/pekko/actor/typed/ActorSystemTest.java | 19 +-
.../apache/pekko/actor/typed/ExtensionsTest.java | 11 +-
.../typed/eventstream/EventStreamDocTest.java | 5 +-
.../eventstream/EventStreamSuperClassDocTest.java | 6 +-
.../actor/typed/javadsl/ActorContextAskTest.java | 24 +-
.../typed/javadsl/ActorContextPipeToSelfTest.java | 39 +-
.../actor/typed/javadsl/ActorLoggingTest.java | 33 +-
.../pekko/actor/typed/javadsl/AdapterTest.java | 23 +-
.../actor/typed/javadsl/BehaviorBuilderTest.java | 23 +-
.../pekko/actor/typed/javadsl/InterceptTest.java | 24 +-
.../actor/typed/javadsl/ReceiveBuilderTest.java | 21 +-
.../pekko/actor/typed/javadsl/RoutersTest.java | 32 +-
.../pekko/actor/typed/javadsl/StashBufferTest.java | 16 +-
.../pekko/actor/typed/javadsl/WatchTest.java | 21 +-
.../pekko/typed/InteractionPatterns3Spec.scala | 35 +-
.../pekko/typed/InteractionPatternsSpec.scala | 12 +-
.../docs/org/apache/pekko/typed/IntroSpec.scala | 10 +-
.../apache/pekko/typed/LoggingDocExamples.scala | 4 +-
.../apache/pekko/typed/StyleGuideDocExamples.scala | 2 +-
.../pekko/typed/extensions/ExtensionDocSpec.scala | 6 +-
.../pekko/typed/fromclassic/ClassicSample.scala | 1 -
.../pekko/actor/typed/ActorContextSpec.scala | 9 +-
.../pekko/actor/typed/ActorRefIgnoreSpec.scala | 6 +-
.../pekko/actor/typed/ActorRefResolverSpec.scala | 8 +-
.../apache/pekko/actor/typed/ActorSystemSpec.scala | 20 +-
.../org/apache/pekko/actor/typed/AskSpec.scala | 7 +-
.../apache/pekko/actor/typed/BehaviorSpec.scala | 8 +-
.../actor/typed/CancelReceiveTimeoutSpec.scala | 106 +
.../apache/pekko/actor/typed/DeferredSpec.scala | 6 +-
.../apache/pekko/actor/typed/ExtensionsSpec.scala | 27 +-
.../apache/pekko/actor/typed/InterceptSpec.scala | 4 +-
.../LocalActorRefProviderLogMessagesSpec.scala | 9 +-
.../apache/pekko/actor/typed/LogMessagesSpec.scala | 7 +-
.../pekko/actor/typed/MailboxSelectorSpec.scala | 8 +-
.../org/apache/pekko/actor/typed/MonitorSpec.scala | 4 +-
.../org/apache/pekko/actor/typed/OrElseSpec.scala | 6 +-
.../org/apache/pekko/actor/typed/PropsSpec.scala | 4 +-
.../pekko/actor/typed/SpawnProtocolSpec.scala | 6 +-
.../apache/pekko/actor/typed/SupervisionSpec.scala | 37 +-
.../apache/pekko/actor/typed/TerminatedSpec.scala | 6 +-
.../org/apache/pekko/actor/typed/TimerSpec.scala | 4 +-
.../pekko/actor/typed/TransformMessagesSpec.scala | 7 +-
.../org/apache/pekko/actor/typed/WatchSpec.scala | 4 +-
.../coexistence/ClassicSupervisingTypedSpec.scala | 9 +-
.../coexistence/TypedSupervisingClassicSpec.scala | 4 +-
.../typed/delivery/ConsumerControllerSpec.scala | 6 +-
.../delivery/DurableProducerControllerSpec.scala | 44 +-
.../typed/delivery/DurableProducerQueueSpec.scala | 8 +-
.../typed/delivery/DurableWorkPullingSpec.scala | 7 +-
.../typed/delivery/ProducerControllerSpec.scala | 7 +-
.../delivery/ReliableDeliveryRandomSpec.scala | 13 +-
.../typed/delivery/ReliableDeliverySpec.scala | 9 +-
.../pekko/actor/typed/delivery/TestConsumer.scala | 10 +-
.../actor/typed/delivery/TestProducerWithAsk.scala | 2 +-
.../actor/typed/delivery/WorkPullingSpec.scala | 4 +-
.../typed/eventstream/EventStreamDocSpec.scala | 1 +
.../actor/typed/eventstream/EventStreamSpec.scala | 4 +-
.../typed/internal/ActorRefSerializationSpec.scala | 7 +-
.../actor/typed/internal/ActorSystemSpec.scala | 23 +-
.../typed/internal/adapter/PropsAdapterSpec.scala | 65 +
.../typed/internal/adpater/PropsAdapterSpec.scala | 34 -
.../receptionist/LocalReceptionistSpec.scala | 10 +-
.../receptionist/ServiceKeySerializationSpec.scala | 4 +-
.../typed/internal/routing/PoolRouterSpec.scala | 4 +-
.../typed/internal/routing/RoutingLogicSpec.scala | 6 +-
.../typed/javadsl/AdaptationFailureSpec.scala | 4 +-
.../pekko/actor/typed/pubsub/LocalPubSubSpec.scala | 4 +-
.../actor/typed/scaladsl/ActorContextAskSpec.scala | 10 +-
.../typed/scaladsl/ActorContextDelegateSpec.scala | 1 +
.../scaladsl/ActorContextPipeToSelfSpec.scala | 7 +-
.../actor/typed/scaladsl/ActorLoggingSpec.scala | 14 +-
.../actor/typed/scaladsl/ActorThreadSpec.scala | 1 +
.../typed/scaladsl/AdaptationFailureSpec.scala | 4 +-
.../typed/scaladsl/DispatcherSelectorSpec.scala | 11 +-
.../actor/typed/scaladsl/GracefulStopSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/LoggerOpsSpec.scala | 7 +-
.../actor/typed/scaladsl/MailboxSelectorSpec.scala | 13 +-
.../actor/typed/scaladsl/MessageAdapterSpec.scala | 10 +-
.../pekko/actor/typed/scaladsl/OnSignalSpec.scala | 4 +-
.../actor/typed/scaladsl/ReceivePartialSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/RoutersSpec.scala | 6 +-
.../actor/typed/scaladsl/StashBufferSpec.scala | 6 +-
.../pekko/actor/typed/scaladsl/StashSpec.scala | 4 +-
.../pekko/actor/typed/scaladsl/StopSpec.scala | 4 +-
.../actor/typed/scaladsl/adapter/AdapterSpec.scala | 8 +-
.../scaladsl/adapter/GuardianStartupSpec.scala | 8 +-
.../actorsystem-close.excludes | 5 +-
.../typed/internal/receptionist/Platform.scala | 26 -
.../typed/internal/receptionist/Platform.scala | 4 +-
.../org/apache/pekko/actor/typed/ActorRef.scala | 2 +-
.../pekko/actor/typed/ActorRefResolver.scala | 10 +-
.../org/apache/pekko/actor/typed/ActorSystem.scala | 32 +-
.../org/apache/pekko/actor/typed/Behavior.scala | 14 +-
.../pekko/actor/typed/BehaviorInterceptor.scala | 8 +-
.../org/apache/pekko/actor/typed/Extensions.scala | 10 +-
.../org/apache/pekko/actor/typed/LogOptions.scala | 4 +-
.../scala/org/apache/pekko/actor/typed/Props.scala | 2 +-
.../apache/pekko/actor/typed/SpawnProtocol.scala | 4 +-
.../pekko/actor/typed/SupervisorStrategy.scala | 18 +-
.../actor/typed/delivery/ConsumerController.scala | 20 +-
.../typed/delivery/DurableProducerQueue.scala | 10 +-
.../actor/typed/delivery/ProducerController.scala | 30 +-
.../delivery/WorkPullingProducerController.scala | 22 +-
.../delivery/internal/ConsumerControllerImpl.scala | 20 +-
.../delivery/internal/ProducerControllerImpl.scala | 15 +-
.../WorkPullingProducerControllerImpl.scala | 4 +-
.../actor/typed/eventstream/EventStream.scala | 6 +-
.../actor/typed/internal/ActorContextImpl.scala | 38 +-
.../actor/typed/internal/ActorFlightRecorder.scala | 5 +-
.../pekko/actor/typed/internal/ActorMdc.scala | 4 +-
.../pekko/actor/typed/internal/ActorRefImpl.scala | 4 +-
.../pekko/actor/typed/internal/BehaviorImpl.scala | 6 +-
.../pekko/actor/typed/internal/CachedProps.scala | 19 +-
.../typed/internal/EventStreamExtension.scala | 4 +-
.../actor/typed/internal/ExtensionsImpl.scala | 16 +-
.../actor/typed/internal/InterceptorImpl.scala | 16 +-
.../pekko/actor/typed/internal/LoggerClass.scala | 17 +-
.../typed/internal/MiscMessageSerializer.scala | 4 +-
.../pekko/actor/typed/internal/PoisonPill.scala | 2 +-
.../actor/typed/internal/StashBufferImpl.scala | 19 +-
.../pekko/actor/typed/internal/Supervision.scala | 36 +-
.../actor/typed/internal/TimerSchedulerImpl.scala | 25 +-
.../internal/WithMdcBehaviorInterceptor.scala | 8 +-
.../typed/internal/adapter/ActorAdapter.scala | 20 +-
.../internal/adapter/ActorContextAdapter.scala | 64 +-
.../typed/internal/adapter/ActorRefAdapter.scala | 4 +-
.../internal/adapter/ActorRefFactoryAdapter.scala | 24 +-
.../internal/adapter/ActorSystemAdapter.scala | 33 +-
.../typed/internal/adapter/PropsAdapter.scala | 62 +-
.../pekko/actor/typed/internal/jfr/Events.scala | 3 +-
.../internal/receptionist/LocalReceptionist.scala | 8 +-
.../internal/receptionist/ReceptionistImpl.scala | 2 +-
.../receptionist/ReceptionistMessages.scala | 9 +-
.../receptionist/ServiceKeySerializer.scala | 4 +-
.../typed/internal/routing/GroupRouterImpl.scala | 2 +-
.../typed/internal/routing/PoolRouterImpl.scala | 8 +-
.../typed/javadsl/AbstractMatchingBehavior.scala | 90 +
.../pekko/actor/typed/javadsl/ActorContext.scala | 18 +-
.../apache/pekko/actor/typed/javadsl/Adapter.scala | 18 +-
.../pekko/actor/typed/javadsl/AskPattern.scala | 11 +-
.../actor/typed/javadsl/BehaviorBuilder.scala | 4 +-
.../pekko/actor/typed/javadsl/Behaviors.scala | 39 +-
.../pekko/actor/typed/javadsl/ReceiveBuilder.scala | 8 +-
.../apache/pekko/actor/typed/javadsl/Routers.scala | 4 +-
.../pekko/actor/typed/javadsl/StashBuffer.scala | 4 +-
.../apache/pekko/actor/typed/pubsub/Topic.scala | 6 +-
.../actor/typed/receptionist/Receptionist.scala | 28 +-
.../pekko/actor/typed/scaladsl/ActorContext.scala | 12 +-
.../pekko/actor/typed/scaladsl/AskPattern.scala | 18 +-
.../pekko/actor/typed/scaladsl/Behaviors.scala | 11 +-
.../actor/typed/scaladsl/TimerScheduler.scala | 4 +-
.../actor/typed/scaladsl/adapter/package.scala | 8 +-
.../pekko/actor/typed/scaladsl/package.scala | 20 +-
.../pekko/japi/function/Functions.scala.template | 4 +-
.../org/apache/pekko/actor/AbstractScheduler.java | 4 +-
.../pekko/dispatch/AbstractBoundedNodeQueue.java | 19 +-
.../apache/pekko/dispatch/AbstractNodeQueue.java | 26 +-
.../io/UnsynchronizedByteArrayInputStream.java | 180 ++
.../org/apache/pekko/japi/pf/AbstractMatch.java | 4 +-
.../apache/pekko/japi/pf/AbstractPFBuilder.java | 4 +-
.../pekko/japi/pf/FSMStateFunctionBuilder.java | 2 +-
.../org/apache/pekko/japi/pf/FSMStopBuilder.java | 2 +-
.../pekko/japi/pf/FSMTransitionHandlerBuilder.java | 2 +-
.../main/java/org/apache/pekko/japi/pf/Match.java | 2 +-
.../java/org/apache/pekko/japi/pf/PFBuilder.java | 2 +-
.../org/apache/pekko/japi/pf/ReceiveBuilder.java | 2 +-
.../java/org/apache/pekko/japi/pf/UnitMatch.java | 4 +-
.../org/apache/pekko/japi/pf/UnitPFBuilder.java | 4 +-
.../java/org/apache/pekko/util/ClassContext.java | 41 -
.../java/org/apache/pekko/util/OptionalUtil.java | 65 +
.../bytestring-indexOf-overload.excludes} | 4 +-
.../actorsystem-close.excludes} | 6 +-
.../add-scheduled-clock.excludes | 8 +-
.../backoff-calculation.excludes | 4 +-
.../fsm-transition-listeners.excludes | 18 +-
.../function-converters.excludes} | 5 +-
.../future-converters.excludes | 16 +-
.../java-duration-converters.excludes | 6 +
.../javaapi-functions.excludes | 1 +
.../javaapi-option.excludes | 12 +
.../option-converters.excludes | 38 -
.../remove-deprecated-methods.excludes | 19 +
.../remove-scala-2.12-support.excludes | 27 +
actor/src/main/resources/reference.conf | 83 +-
.../org/apache/pekko/compat/Future.scala | 57 -
.../org/apache/pekko/compat/PartialFunction.scala | 35 -
.../internal/SameThreadExecutionContext.scala | 39 -
.../pekko/dispatch/internal/ScalaBatchable.scala | 32 -
.../org/apache/pekko/util/ByteIterator.scala | 696 -----
.../org/apache/pekko/util/ByteString.scala | 1456 ----------
.../org/apache/pekko/util/FunctionConverters.scala | 562 ----
.../org/apache/pekko/util/FutureConverters.scala | 43 -
.../org/apache/pekko/util/OptionConverters.scala | 91 -
.../org/apache/pekko/util/ccompat/CompatImpl.scala | 31 -
.../org/apache/pekko/util/ccompat/package.scala | 154 -
.../org/apache/pekko/compat/Future.scala | 59 -
.../pekko/util/ccompat/ccompatUsedUntil213.scala | 27 -
.../org/apache/pekko/util/ccompat/package.scala | 40 -
.../org/apache/pekko/compat/PartialFunction.scala | 31 -
.../internal/SameThreadExecutionContext.scala | 29 -
.../org/apache/pekko/util/ByteIterator.scala | 56 +-
.../org/apache/pekko/util/ByteString.scala | 1503 ----------
.../org/apache/pekko/util/FutureConverters.scala | 45 -
.../org/apache/pekko/util/OptionConverters.scala | 85 -
.../apache/pekko/util/JavaDurationConverters.scala | 35 -
.../internal/SameThreadExecutionContext.scala | 30 -
.../pekko/dispatch/internal/ScalaBatchable.scala | 32 -
.../org/apache/pekko/util/ByteIterator.scala | 186 +-
.../scala-3/org/apache/pekko/util/ByteString.scala | 1507 ----------
.../org/apache/pekko/util/FutureConverters.scala | 41 -
.../apache/pekko/util/JavaDurationConverters.scala | 39 -
.../org/apache/pekko/util/OptionConverters.scala | 79 -
.../main/scala/org/apache/pekko/PekkoVersion.scala | 38 +-
.../org/apache/pekko/actor/AbstractActor.scala | 67 +-
.../scala/org/apache/pekko/actor/AbstractFSM.scala | 48 +-
.../org/apache/pekko/actor/AbstractProps.scala | 14 +-
.../main/scala/org/apache/pekko/actor/Actor.scala | 21 +-
.../scala/org/apache/pekko/actor/ActorCell.scala | 15 +-
.../scala/org/apache/pekko/actor/ActorPath.scala | 16 +-
.../scala/org/apache/pekko/actor/ActorRef.scala | 6 +-
.../org/apache/pekko/actor/ActorRefProvider.scala | 14 +-
.../org/apache/pekko/actor/ActorSelection.scala | 24 +-
.../scala/org/apache/pekko/actor/ActorSystem.scala | 112 +-
.../scala/org/apache/pekko/actor/Address.scala | 4 +-
.../apache/pekko/actor/CoordinatedShutdown.scala | 23 +-
.../scala/org/apache/pekko/actor/Deployer.scala | 16 +-
.../org/apache/pekko/actor/DynamicAccess.scala | 6 +-
.../scala/org/apache/pekko/actor/Extension.scala | 2 +-
.../main/scala/org/apache/pekko/actor/FSM.scala | 62 +-
.../org/apache/pekko/actor/FaultHandling.scala | 57 +-
.../apache/pekko/actor/IndirectActorProducer.scala | 21 +-
.../pekko/actor/LightArrayRevolverScheduler.scala | 22 +-
.../main/scala/org/apache/pekko/actor/Props.scala | 14 +-
.../pekko/actor/ReflectiveDynamicAccess.scala | 10 +-
.../apache/pekko/actor/RepointableActorRef.scala | 28 +-
.../scala/org/apache/pekko/actor/Scheduler.scala | 25 +-
.../main/scala/org/apache/pekko/actor/Stash.scala | 2 +-
.../main/scala/org/apache/pekko/actor/Timers.scala | 19 +-
.../org/apache/pekko/actor/dungeon/Children.scala | 17 +-
.../pekko/actor/dungeon/ChildrenContainer.scala | 4 +-
.../apache/pekko/actor/dungeon/DeathWatch.scala | 5 +-
.../org/apache/pekko/actor/dungeon/Dispatch.scala | 10 +-
.../pekko/actor/dungeon/TimerSchedulerImpl.scala | 2 +-
.../pekko/actor/setup/ActorSystemSetup.scala | 14 +-
.../apache/pekko/dispatch/AbstractDispatcher.scala | 117 +-
.../pekko/dispatch/BalancingDispatcher.scala | 4 +-
.../apache/pekko/dispatch/BatchingExecutor.scala | 17 +-
.../apache/pekko/dispatch/CompletionStages.scala | 27 +-
.../org/apache/pekko/dispatch/Dispatcher.scala | 5 +-
.../org/apache/pekko/dispatch/Dispatchers.scala | 10 +-
.../dispatch/ForkJoinExecutorConfigurator.scala | 87 +-
.../scala/org/apache/pekko/dispatch/Future.scala | 19 +-
.../scala/org/apache/pekko/dispatch/Mailbox.scala | 106 +-
.../org/apache/pekko/dispatch/Mailboxes.scala | 40 +-
.../apache/pekko/dispatch/PinnedDispatcher.scala | 4 +-
.../apache/pekko/dispatch/ThreadPoolBuilder.scala | 94 +-
.../pekko/dispatch/VirtualThreadSupport.scala | 75 +-
.../dispatch/VirtualizedExecutorService.scala | 97 +-
.../pekko/dispatch/affinity/AffinityPool.scala | 75 +-
.../pekko/dispatch/internal/ScalaBatchable.scala | 0
.../pekko/dispatch/sysmsg/SystemMessage.scala | 2 +-
.../event/ActorClassificationUnsubscriber.scala | 5 +-
.../scala/org/apache/pekko/event/EventStream.scala | 19 +-
.../org/apache/pekko/event/LoggerMailbox.scala | 10 +-
.../scala/org/apache/pekko/event/Logging.scala | 236 +-
.../org/apache/pekko/event/LoggingReceive.scala | 5 +-
.../org/apache/pekko/io/DirectByteBufferPool.scala | 4 +-
actor/src/main/scala/org/apache/pekko/io/Dns.scala | 8 +-
.../scala/org/apache/pekko/io/DnsProvider.scala | 4 +-
.../src/main/scala/org/apache/pekko/io/Inet.scala | 56 +-
.../apache/pekko/io/InetAddressDnsResolver.scala | 4 +-
.../org/apache/pekko/io/SelectionHandler.scala | 22 +-
.../scala/org/apache/pekko/io/SimpleDnsCache.scala | 4 +-
.../org/apache/pekko/io/SimpleDnsManager.scala | 2 +
actor/src/main/scala/org/apache/pekko/io/Tcp.scala | 20 +-
.../scala/org/apache/pekko/io/TcpConnection.scala | 32 +-
.../apache/pekko/io/TcpIncomingConnection.scala | 3 +-
.../scala/org/apache/pekko/io/TcpManager.scala | 2 +-
.../apache/pekko/io/TcpOutgoingConnection.scala | 25 +-
actor/src/main/scala/org/apache/pekko/io/Udp.scala | 14 +-
.../scala/org/apache/pekko/io/UdpConnected.scala | 7 +-
.../scala/org/apache/pekko/io/UdpConnection.scala | 11 +-
.../scala/org/apache/pekko/io/UdpListener.scala | 5 +-
.../scala/org/apache/pekko/io/UdpManager.scala | 4 +-
.../main/scala/org/apache/pekko/io/UdpSender.scala | 52 +-
.../org/apache/pekko/io/dns/CachePolicy.scala | 8 +-
.../org/apache/pekko/io/dns/DnsProtocol.scala | 4 +-
.../apache/pekko/io/dns/DnsResourceRecords.scala | 15 +-
.../org/apache/pekko/io/dns/DnsSettings.scala | 12 +-
.../org/apache/pekko/io/dns/IdGenerator.scala | 10 +-
.../pekko/io/dns/internal/AsyncDnsManager.scala | 4 +-
.../pekko/io/dns/internal/AsyncDnsResolver.scala | 468 ++-
.../apache/pekko/io/dns/internal/DnsClient.scala | 43 +-
.../apache/pekko/io/dns/internal/DnsMessage.scala | 3 +-
.../pekko/io/dns/internal/ResolvConfParser.scala | 4 +-
.../pekko/io/dns/internal/TcpDnsClient.scala | 4 +-
.../main/scala/org/apache/pekko/japi/JavaAPI.scala | 17 +-
.../scala/org/apache/pekko/japi/Throwables.scala | 11 +
.../org/apache/pekko/japi/function/Function.scala | 18 +-
.../org/apache/pekko/pattern/AskSupport.scala | 53 +-
.../org/apache/pekko/pattern/BackoffOptions.scala | 16 +-
.../apache/pekko/pattern/BackoffSupervisor.scala | 4 +-
.../org/apache/pekko/pattern/CircuitBreaker.scala | 66 +-
.../pekko/pattern/CircuitBreakersRegistry.scala | 6 +-
.../pekko/pattern/FutureTimeoutSupport.scala | 34 +-
.../apache/pekko/pattern/GracefulStopSupport.scala | 4 +-
.../scala/org/apache/pekko/pattern/Patterns.scala | 134 +-
.../org/apache/pekko/pattern/PipeToSupport.scala | 4 +-
.../org/apache/pekko/pattern/RetrySupport.scala | 32 +-
.../org/apache/pekko/pattern/StatusReply.scala | 90 +-
.../internal/BackoffOnRestartSupervisor.scala | 2 +-
.../pattern/internal/CircuitBreakerTelemetry.scala | 7 +-
.../scala/org/apache/pekko/pattern/package.scala | 6 +-
.../scala/org/apache/pekko/routing/Balancing.scala | 10 +-
.../scala/org/apache/pekko/routing/Broadcast.scala | 8 +-
.../org/apache/pekko/routing/ConsistentHash.scala | 11 +-
.../apache/pekko/routing/ConsistentHashing.scala | 4 +-
.../org/apache/pekko/routing/MurmurHash.scala | 3 -
.../routing/OptimalSizeExploringResizer.scala | 11 +-
.../scala/org/apache/pekko/routing/Random.scala | 8 +-
.../scala/org/apache/pekko/routing/Resizer.scala | 4 +-
.../org/apache/pekko/routing/RoundRobin.scala | 8 +-
.../org/apache/pekko/routing/RoutedActorCell.scala | 2 -
.../org/apache/pekko/routing/RoutedActorRef.scala | 2 +-
.../scala/org/apache/pekko/routing/Router.scala | 6 +-
.../org/apache/pekko/routing/RouterConfig.scala | 18 +-
.../routing/ScatterGatherFirstCompleted.scala | 14 +-
.../org/apache/pekko/routing/SmallestMailbox.scala | 12 +-
.../org/apache/pekko/routing/TailChopping.scala | 10 +-
.../pekko/serialization/AsyncSerializer.scala | 2 +-
.../pekko/serialization/PrimitiveSerializers.scala | 10 +-
.../apache/pekko/serialization/Serialization.scala | 94 +-
.../pekko/serialization/SerializationSetup.scala | 8 +-
.../apache/pekko/serialization/Serializer.scala | 58 +-
.../apache/pekko/util/BoundedBlockingQueue.scala | 14 +-
.../scala/org/apache/pekko/util/BoxedType.scala | 4 +-
.../scala/org/apache/pekko/util/ByteString.scala | 3061 ++++++++++++++++++++
.../pekko/util/ClassLoaderObjectInputStream.scala | 2 +-
.../main/scala/org/apache/pekko/util/Clock.scala | 121 +
.../scala/org/apache/pekko/util/Collections.scala | 28 +-
.../scala/org/apache/pekko/util/ConstantFun.scala | 6 +-
.../org/apache/pekko/util/DoubleLinkedList.scala | 10 +-
.../apache/pekko/util/FlightRecorderLoader.scala | 4 +-
.../org/apache/pekko/util/FrequencyList.scala | 10 +-
.../org/apache/pekko/util/FrequencySketch.scala | 65 +-
.../main/scala/org/apache/pekko/util/Helpers.scala | 4 +-
.../org/apache/pekko/util/ImmutableIntMap.scala | 8 +-
.../main/scala/org/apache/pekko/util/Index.scala | 3 +-
.../scala/org/apache/pekko/util/JavaVersion.scala | 12 +-
.../scala/org/apache/pekko/util/LineNumbers.scala | 4 +-
.../scala/org/apache/pekko/util/LockUtil.scala | 10 -
.../scala/org/apache/pekko/util/ManifestInfo.scala | 3 +-
.../scala/org/apache/pekko/util/OptionVal.scala | 7 +-
.../scala/org/apache/pekko/util/RecencyList.scala | 22 +-
.../main/scala/org/apache/pekko/util/Reflect.scala | 29 +-
.../scala/org/apache/pekko/util/SWARUtil.scala | 456 +++
.../apache/pekko/util/SegmentedRecencyList.scala | 12 +-
.../apache/pekko/util/StablePriorityQueue.scala | 2 +-
.../org/apache/pekko/util/SubclassifiedIndex.scala | 5 +-
.../main/scala/org/apache/pekko/util/Timeout.scala | 4 +-
.../scala/org/apache/pekko/util/TokenBucket.scala | 6 +-
.../org/apache/pekko/util/TypedMultiMap.scala | 2 +-
.../main/scala/org/apache/pekko/util/Unused.scala | 37 -
.../main/scala/org/apache/pekko/util/Version.scala | 2 +-
bench-jmh/README.md | 2 +-
.../test => bench-jmh/src/main}/resources/keystore | Bin
.../src/main}/resources/truststore | Bin
.../main/scala/org/apache/pekko/BenchRunner.scala | 2 +-
.../org/apache/pekko/actor/ActorBenchmark.scala | 12 +-
.../pekko/actor/ActorCreationBenchmark.scala | 9 +-
.../actor/AffinityPoolComparativeBenchmark.scala | 3 +-
.../actor/AffinityPoolIdleCPULevelBenchmark.scala | 3 +-
.../AffinityPoolRequestResponseBenchmark.scala | 3 +-
.../pekko/actor/ForkJoinActorBenchmark.scala | 11 +-
.../org/apache/pekko/actor/JCToolsMailbox.scala | 3 +-
.../apache/pekko/actor/ManyToOneArrayMailbox.scala | 3 +-
.../pekko/actor/RouterPoolCreationBenchmark.scala | 7 +-
.../org/apache/pekko/actor/ScheduleBenchmark.scala | 6 +-
.../pekko/actor/StashCreationBenchmark.scala | 12 +-
.../org/apache/pekko/actor/TellOnlyBenchmark.scala | 12 +-
.../pekko/actor/typed/TypedActorBenchmark.scala | 9 +-
.../pekko/actor/typed/TypedBenchmarkActors.scala | 4 +-
.../actor/typed/TypedForkJoinActorBenchmark.scala | 9 +-
.../typed/delivery/ReliableDeliveryBenchmark.scala | 14 +-
.../ddata/ORSetSerializationBenchmark.scala | 3 +-
.../pekko/dispatch/CachingConfigBenchmark.scala | 3 +-
.../apache/pekko/dispatch/NodeQueueBenchmark.scala | 3 +-
.../apache/pekko/io/dns/IdGeneratorBanchmark.scala | 6 +-
.../persistence/LevelDbBatchingBenchmark.scala | 11 +-
.../PersistenceActorDeferBenchmark.scala | 6 +-
.../persistence/PersistentActorBenchmark.scala | 6 +-
...tentActorWithAtLeastOnceDeliveryBenchmark.scala | 4 +-
.../pekko/remote/artery/CodecBenchmark.scala | 7 +-
.../pekko/remote/artery/SendQueueBenchmark.scala | 3 +-
.../SerializationFormatCacheBenchmark.scala | 23 +-
.../jackson/JacksonSerializationBench.scala | 5 +-
.../ActorGraphInterpreterBoundaryBenchmark.scala | 186 ++
.../pekko/stream/ActorRefSourceBenchmark.scala | 107 +
.../org/apache/pekko/stream/AskBenchmark.scala | 3 +-
.../stream/AsyncBoundaryThroughputBenchmark.scala | 123 +
.../pekko/stream/BroadcastHubBenchRunner.scala | 113 +
.../pekko/stream/BroadcastHubBenchmark.scala | 141 +
.../org/apache/pekko/stream/CollectBenchmark.scala | 17 +-
.../pekko/stream/FlatMapConcatBenchmark.scala | 3 +-
.../org/apache/pekko/stream/FlowMapBenchmark.scala | 5 +-
.../org/apache/pekko/stream/FramingBenchmark.scala | 5 +-
.../apache/pekko/stream/FusedGraphsBenchmark.scala | 7 +-
.../stream/GraphStageConstructionBenchmark.scala | 181 ++
.../apache/pekko/stream/InterpreterBenchmark.scala | 71 +-
.../pekko/stream/LazyFutureSourceBenchmark.scala | 3 +-
.../apache/pekko/stream/MapAsyncBenchmark.scala | 3 +-
.../pekko/stream/MaterializerWiringBenchmark.scala | 132 +
.../pekko/stream/PartitionHubBenchmark.scala | 3 +-
.../apache/pekko/stream/RangeSourceBenchmark.scala | 103 +
.../apache/pekko/stream/SourceRefBenchmark.scala | 3 +-
.../pekko/stream/StageActorRefBenchmark.scala | 136 +
.../pekko/stream/ZipWithIndexBenchmark.scala | 4 +-
.../org/apache/pekko/stream/io/TlsBenchmark.scala | 217 ++
.../apache/pekko/util/ArrayCopyOf_Benchmark.scala | 4 +-
.../util/ByteStringParser_readNum_Benchmark.scala | 86 +
.../pekko/util/ByteString_append_Benchmark.scala | 48 +
.../util/ByteString_asInputStream_Benchmark.scala | 8 +-
.../util/ByteString_concat3way_Benchmark.scala | 180 ++
.../util/ByteString_indexOfSlice_Benchmark.scala | 39 +
.../ByteString_lastIndexOfSlice_Benchmark.scala | 39 +
.../pekko/util/ByteString_putInt_Benchmark.scala | 101 +
.../pekko/util/ByteString_startEnd_Benchmark.scala | 50 +
.../pekko/util/FastFrequencySketchBenchmark.scala | 14 +-
.../pekko/util/FrequencySketchBenchmark.scala | 14 +-
.../apache/pekko/util/ImmutableIntMapBench.scala | 12 +-
build.sbt | 65 +-
.../protobuf/msg/ClusterMetricsMessages.java | 344 ++-
.../cluster/metrics/ClusterMetricsCollector.scala | 15 +-
.../cluster/metrics/ClusterMetricsExtension.scala | 8 +-
.../cluster/metrics/ClusterMetricsRouting.scala | 6 +-
.../cluster/metrics/ClusterMetricsSettings.scala | 4 +-
.../cluster/metrics/ClusterMetricsStrategy.scala | 6 +-
.../org/apache/pekko/cluster/metrics/Metric.scala | 5 +-
.../pekko/cluster/metrics/MetricsCollector.scala | 2 +-
.../metrics/protobuf/MessageSerializer.scala | 28 +-
.../metrics/protobuf/NumberInputStream.scala | 2 +-
.../metrics/ClusterMetricsExtensionSpec.scala | 4 +-
.../metrics/ClusterMetricsRoutingSpec.scala | 11 +-
.../metrics/ClusterMetricsRoutingSpec.scala | 6 +-
.../metrics/ClusterMetricsSettingsSpec.scala | 4 +-
.../apache/pekko/cluster/metrics/EWMASpec.scala | 7 +-
.../apache/pekko/cluster/metrics/MetricSpec.scala | 10 +-
.../cluster/metrics/MetricsCollectorSpec.scala | 3 +-
.../apache/pekko/cluster/metrics/TestUtil.scala | 3 +-
.../cluster/metrics/WeightedRouteesSpec.scala | 4 +-
.../metrics/protobuf/NumberInputStreamSpec.scala | 1 +
.../typed/internal/protobuf/ShardingMessages.java | 2972 ++++++++++++++++++-
.../dynamic-scaling.excludes | 6 +-
.../remove-old-passivation-strategy.excludes | 6 +-
.../throttle-keep-alive-messages.excludes | 4 +-
.../src/main/protobuf/ShardingMessages.proto | 25 +-
.../src/main/resources/reference.conf | 11 +-
.../sharding/typed/ClusterShardingQuery.scala | 12 +-
.../sharding/typed/ClusterShardingSettings.scala | 101 +-
.../sharding/typed/ReplicatedEntityProvider.scala | 14 +-
.../typed/ReplicatedShardingExtension.scala | 7 +-
.../typed/ShardedDaemonProcessCommand.scala | 119 +
.../typed/ShardedDaemonProcessSettings.scala | 72 +-
.../sharding/typed/ShardingMessageExtractor.scala | 12 +-
.../delivery/ShardingConsumerController.scala | 8 +-
.../delivery/ShardingProducerController.scala | 34 +-
.../internal/ShardingConsumerControllerImpl.scala | 2 +-
.../internal/ShardingProducerControllerImpl.scala | 19 +-
.../typed/internal/ClusterShardingImpl.scala | 34 +-
.../ClusterShardingTypedSerializable.scala | 11 +-
.../JoinConfigCompatCheckerClusterSharding.scala | 4 +-
.../cluster/sharding/typed/internal/Murmur2.scala | 5 +-
.../internal/ReplicatedShardingExtensionImpl.scala | 23 +-
.../internal/ShardedDaemonProcessCoordinator.scala | 395 +++
.../typed/internal/ShardedDaemonProcessId.scala | 76 +
.../typed/internal/ShardedDaemonProcessImpl.scala | 280 +-
.../typed/internal/ShardedDaemonProcessState.scala | 148 +
.../typed/internal/ShardingSerializer.scala | 156 +-
.../typed/internal/testkit/TestEntityRefImpl.scala | 13 +-
.../sharding/typed/javadsl/ClusterSharding.scala | 15 +-
.../typed/javadsl/ShardedDaemonProcess.scala | 62 +-
.../sharding/typed/scaladsl/ClusterSharding.scala | 13 +-
.../typed/scaladsl/ShardedDaemonProcess.scala | 57 +-
.../ClusterShardingRememberEntitiesPerfSpec.scala | 12 +-
.../ClusterShardingPreparingForShutdownSpec.scala | 7 +-
.../sharding/typed/ClusterShardingStatsSpec.scala | 7 +-
.../typed/MultiDcClusterShardingSpec.scala | 7 +-
.../sharding/typed/ReplicatedShardingSpec.scala | 8 +-
.../sharding/typed/ShardedDaemonProcessSpec.scala | 7 +-
.../typed/delivery/DeliveryThroughputSpec.scala | 16 +-
.../jdocs/delivery/PointToPointDocExample.java | 38 +-
.../java/jdocs/delivery/ShardingDocExample.java | 128 +-
.../java/jdocs/delivery/WorkPullingDocExample.java | 132 +-
.../sharding/typed/AccountExampleDocTest.java | 39 +-
.../AccountExamplePersistenceProbeDocTest.java | 163 ++
.../cluster/sharding/typed/AccountExampleTest.java | 32 +-
.../AccountExampleWithEventHandlersInState.java | 106 +-
.../typed/AccountExampleWithMutableState.java | 106 +-
.../typed/AccountExampleWithNullDurableState.java | 81 +-
.../typed/AccountExampleWithNullState.java | 106 +-
...stentHashingShardAllocationCompileOnlyTest.java | 141 +
.../ExternalShardAllocationCompileOnlyTest.java | 4 +-
.../HelloWorldEventSourcedEntityExampleTest.java | 24 +-
.../typed/HelloWorldPersistentEntityExample.java | 3 +-
.../typed/ReplicatedShardingCompileOnlySpec.java | 4 +-
.../sharding/typed/ShardingCompileOnlyTest.java | 22 +-
.../typed/ShardingReplyCompileOnlyTest.java | 18 +-
.../sharding/typed/ReplicatedShardingTest.java | 56 +-
.../javadsl/ClusterShardingPersistenceTest.java | 22 +-
.../ShardedDaemonProcessCompileOnlyTest.java | 64 +-
...edEntityWithEnforcedRepliesCompileOnlyTest.java | 16 +-
.../AccountExamplePersistenceProbeDocSpec.scala | 97 +
...tentHashingShardAllocationCompileOnlySpec.scala | 94 +
...urableStateStoreQueryUsageCompileOnlySpec.scala | 2 +-
.../ExternalShardAllocationCompileOnlySpec.scala | 2 +-
.../typed/HelloWorldPersistentEntityExample.scala | 2 +-
.../typed/ReplicatedShardingCompileOnlySpec.scala | 2 +-
.../pekko/cluster/sharding/FlightRecording.scala | 2 +-
...oinConfigCompatCheckerClusterShardingSpec.scala | 13 +-
.../ReplicatedShardingDirectReplicationSpec.scala | 14 +-
.../sharding/typed/ReplicatedShardingSpec.scala | 21 +-
.../sharding/typed/ShardingSerializerSpec.scala | 7 +-
.../typed/delivery/DurableShardingSpec.scala | 16 +-
.../delivery/ReliableDeliveryShardingSpec.scala | 26 +-
.../sharding/typed/internal/Murmur2Spec.scala | 4 +-
.../internal/ShardedDaemonProcessIdSpec.scala | 68 +
.../internal/ShardedDaemonProcessStateSpec.scala | 45 +
.../scaladsl/ClusterShardingPersistenceSpec.scala | 9 +-
.../typed/scaladsl/ClusterShardingSpec.scala | 9 +-
.../typed/scaladsl/ClusterShardingStateSpec.scala | 4 +-
.../typed/scaladsl/ClusterShardingStatsSpec.scala | 4 +-
.../typed/scaladsl/ShardedDaemonProcessSpec.scala | 89 +-
.../typed/testkit/scaladsl/TestEntityRefSpec.scala | 4 +-
.../protobuf/msg/ClusterShardingMessages.java | 1567 +++++++---
.../consistent-hashing-allocation.excludes | 21 +-
.../remove-deprecated-methods.excludes | 4 +
...es => remove-old-passivation-strategy.excludes} | 9 +-
.../main/protobuf/ClusterShardingMessages.proto | 4 +
cluster-sharding/src/main/resources/reference.conf | 25 +-
.../pekko/cluster/sharding/ClusterSharding.scala | 283 +-
.../sharding/ClusterShardingHealthCheck.scala | 46 +-
.../cluster/sharding/ClusterShardingSettings.scala | 111 +-
.../ConsistentHashingShardAllocationStrategy.scala | 163 ++
.../sharding/JoinConfigCompatCheckSharding.scala | 4 +-
.../RemoveInternalClusterShardingData.scala | 4 +-
.../org/apache/pekko/cluster/sharding/Shard.scala | 39 +-
.../pekko/cluster/sharding/ShardCoordinator.scala | 119 +-
.../pekko/cluster/sharding/ShardRegion.scala | 87 +-
.../cluster/sharding/ShardingFlightRecorder.scala | 2 +-
.../external/ExternalShardAllocationStrategy.scala | 15 +-
.../cluster/sharding/external/ShardLocations.scala | 3 +-
.../ExternalShardAllocationClientImpl.scala | 8 +-
.../AbstractLeastShardAllocationStrategy.scala | 93 +-
...egy.scala => ClusterShardAllocationMixin.scala} | 75 +-
.../DDataRememberEntitiesCoordinatorStore.scala | 40 +-
.../internal/DDataRememberEntitiesShardStore.scala | 87 +-
.../internal/EntityPassivationStrategy.scala | 85 +-
...ntSourcedRememberEntitiesCoordinatorStore.scala | 8 +-
.../internal/LeastShardAllocationStrategy.scala | 12 +-
.../sharding/internal/RememberEntitiesStore.scala | 2 +-
.../sharding/internal/RememberEntityStarter.scala | 99 +-
.../cluster/sharding/internal/jfr/Events.scala | 6 +-
.../ClusterShardingMessageSerializer.scala | 47 +-
.../pekko/cluster/sbr/GremlinController.scala | 3 +-
.../RandomizedBrainResolverIntegrationSpec.scala | 22 +-
.../sbr/SplitBrainResolverIntegrationSpec.scala | 11 +-
.../ClusterShardCoordinatorDowning2Spec.scala | 5 +-
.../ClusterShardCoordinatorDowningSpec.scala | 5 +-
.../ClusterShardingCoordinatorRoleSpec.scala | 175 ++
.../sharding/ClusterShardingFailureSpec.scala | 2 -
.../sharding/ClusterShardingGetStateSpec.scala | 4 +-
.../sharding/ClusterShardingGetStatsSpec.scala | 1 +
...ClusterShardingGracefulShutdownOldestSpec.scala | 4 +-
.../ClusterShardingGracefulShutdownSpec.scala | 7 +-
.../sharding/ClusterShardingLeavingSpec.scala | 2 -
.../sharding/ClusterShardingMinMembersSpec.scala | 2 -
.../sharding/ClusterShardingQueriesSpec.scala | 6 +-
...rShardingRememberEntitiesNewExtractorSpec.scala | 4 +-
.../ClusterShardingRememberEntitiesSpec.scala | 8 +-
.../ClusterShardingRolePartitioningSpec.scala | 4 +-
.../cluster/sharding/ClusterShardingSpec.scala | 7 +-
.../sharding/ExternalShardAllocationSpec.scala | 6 +-
.../sharding/MultiDcClusterShardingSpec.scala | 9 +-
.../sharding/MultiNodeClusterShardingConfig.scala | 9 +-
.../sharding/MultiNodeClusterShardingSpec.scala | 8 +-
.../RollingUpdateShardAllocationSpec.scala | 8 +-
.../sharding/ClusterShardingHealthCheckSpec.scala | 71 +-
.../sharding/ClusterShardingInternalsSpec.scala | 2 +-
.../sharding/ClusterShardingLeaseSpec.scala | 6 +-
.../sharding/ClusterShardingSettingsSpec.scala | 17 +-
.../sharding/ConcurrentStartupShardingSpec.scala | 5 +-
...sistentHashingShardAllocationStrategySpec.scala | 257 ++
.../sharding/CoordinatedShutdownShardingSpec.scala | 2 -
...eprecatedLeastShardAllocationStrategySpec.scala | 28 +-
.../pekko/cluster/sharding/EntitiesSpec.scala | 1 +
.../cluster/sharding/EntityTerminationSpec.scala | 7 +-
.../JoinConfigCompatCheckShardingSpec.scala | 9 +-
...eastShardAllocationStrategyRandomizedSpec.scala | 4 +-
.../LeastShardAllocationStrategySpec.scala | 27 +-
.../sharding/PersistentShardingMigrationSpec.scala | 13 +-
.../RememberEntitiesAndStartEntitySpec.scala | 13 +-
.../RememberEntitiesBatchedUpdatesSpec.scala | 4 +-
.../sharding/RememberEntitiesFailureSpec.scala | 14 +-
...ememberEntitiesShardIdExtractorChangeSpec.scala | 8 +-
.../RemoveInternalClusterShardingDataSpec.scala | 9 +-
.../sharding/ShardRegionDataTypesSpec.scala | 116 +
.../pekko/cluster/sharding/ShardRegionSpec.scala | 8 +-
.../cluster/sharding/ShardWithLeaseSpec.scala | 12 +-
.../cluster/sharding/ShardingQueriesSpec.scala | 6 +-
.../pekko/cluster/sharding/StartEntitySpec.scala | 6 +-
.../pekko/cluster/sharding/StopShardsSpec.scala | 145 +
.../pekko/cluster/sharding/SupervisionSpec.scala | 6 +-
.../internal/RememberEntitiesShardStoreSpec.scala | 6 +-
.../internal/RememberEntitiesStarterSpec.scala | 129 +-
.../sharding/passivation/CompositeSpec.scala | 9 +-
.../passivation/EntityPassivationSpec.scala | 17 +-
.../HillClimbingAdmissionOptimizerSpec.scala | 1 +
.../cluster/sharding/passivation/IdleSpec.scala | 8 +-
.../passivation/LeastFrequentlyUsedSpec.scala | 9 +-
.../passivation/LeastRecentlyUsedSpec.scala | 9 +-
.../passivation/MostRecentlyUsedSpec.scala | 9 +-
.../passivation/simulator/AccessPattern.scala | 7 +-
.../sharding/passivation/simulator/Simulator.scala | 67 +-
.../passivation/simulator/SimulatorSettings.scala | 29 +-
.../passivation/simulator/SimulatorStats.scala | 4 +-
.../ClusterShardingMessageSerializerSpec.scala | 5 +
.../client/protobuf/msg/ClusterClientMessages.java | 39 +-
.../protobuf/msg/DistributedPubSubMessages.java | 344 ++-
.../pekko/cluster/client/ClusterClient.scala | 15 +-
.../protobuf/ClusterClientMessageSerializer.scala | 2 +-
.../cluster/pubsub/DistributedPubSubMediator.scala | 18 +-
.../DistributedPubSubMessageSerializer.scala | 23 +-
.../singleton/ClusterSingletonManager.scala | 22 +-
.../cluster/singleton/ClusterSingletonProxy.scala | 14 +-
.../cluster/client/ClusterClientHandoverSpec.scala | 6 +-
.../pekko/cluster/client/ClusterClientSpec.scala | 7 +-
.../cluster/client/ClusterClientStopSpec.scala | 9 +-
.../pubsub/DistributedPubSubMediatorSpec.scala | 4 +-
.../pubsub/DistributedPubSubRestartSpec.scala | 4 +-
.../ClusterSingletonManagerChaosSpec.scala | 4 +-
.../ClusterSingletonManagerDownedSpec.scala | 6 +-
.../ClusterSingletonManagerLeaseSpec.scala | 4 +-
.../ClusterSingletonManagerLeave2Spec.scala | 4 +-
.../ClusterSingletonManagerLeaveSpec.scala | 4 +-
...rSingletonManagerPreparingForShutdownSpec.scala | 5 +-
.../singleton/ClusterSingletonManagerSpec.scala | 4 +-
.../ClusterSingletonManagerStartupSpec.scala | 4 +-
.../singleton/MultiDcSingletonManagerSpec.scala | 4 +-
.../pekko/cluster/client/ClusterClientTest.java | 23 +-
.../pubsub/DistributedPubSubMediatorTest.java | 15 +-
.../DistributedPubSubMediatorRouterSpec.scala | 7 +-
.../singleton/ClusterSingletonLeaseSpec.scala | 4 +-
.../ClusterSingletonLeavingSpeedSpec.scala | 6 +-
.../singleton/ClusterSingletonProxySpec.scala | 11 +-
.../singleton/ClusterSingletonRestart2Spec.scala | 6 +-
.../singleton/ClusterSingletonRestartSpec.scala | 6 +-
.../typed/internal/protobuf/ClusterMessages.java | 64 +-
.../typed/internal/protobuf/ReliableDelivery.java | 283 +-
.../receptionist/ClusterReceptionistProtocol.scala | 27 -
.../receptionist/ClusterReceptionistProtocol.scala | 2 +-
.../ddata/typed/internal/ReplicatorBehavior.scala | 80 +-
.../ddata/typed/javadsl/DistributedData.scala | 15 +-
.../cluster/ddata/typed/javadsl/Replicator.scala | 20 +-
.../typed/javadsl/ReplicatorMessageAdapter.scala | 15 +-
.../ddata/typed/javadsl/ReplicatorSettings.scala | 6 +-
.../ddata/typed/scaladsl/DistributedData.scala | 14 +-
.../cluster/ddata/typed/scaladsl/Replicator.scala | 9 +
.../typed/scaladsl/ReplicatorMessageAdapter.scala | 8 +-
.../ddata/typed/scaladsl/ReplicatorSettings.scala | 8 +-
.../org/apache/pekko/cluster/typed/Cluster.scala | 36 +-
.../pekko/cluster/typed/ClusterSingleton.scala | 31 +-
.../typed/internal/AdaptedClusterImpl.scala | 10 +-
.../internal/AdaptedClusterSingletonImpl.scala | 10 +-
.../internal/PekkoClusterTypedSerializer.scala | 8 +-
.../delivery/ReliableDeliverySerializer.scala | 34 +-
.../receptionist/ClusterReceptionist.scala | 20 +-
.../ClusterReceptionistConfigCompatChecker.scala | 4 +-
.../receptionist/ClusterReceptionistSettings.scala | 6 +-
.../typed/internal/receptionist/Registry.scala | 12 +-
.../cluster/typed/ChunkLargeMessageSpec.scala | 3 +-
.../typed/MultiDcClusterSingletonSpec.scala | 4 +-
.../cluster/typed/MultiNodeTypedClusterSpec.scala | 12 +-
.../apache/pekko/cluster/typed/PubSubSpec.scala | 4 +-
.../ClusterReceptionistUnreachabilitySpec.scala | 4 +-
.../ddata/typed/javadsl/ReplicatorDocSample.java | 56 +-
.../ddata/typed/javadsl/ReplicatorDocTest.java | 24 +-
.../cluster/typed/BasicClusterExampleTest.java | 2 +-
.../cluster/typed/PingSerializerExampleTest.java | 4 +-
.../cluster/typed/SingletonCompileOnlyTest.java | 11 +-
.../apache/pekko/cluster/typed/ClusterApiTest.java | 5 +-
.../cluster/typed/BasicClusterExampleSpec.scala | 10 +-
.../cluster/typed/DistributedPubSubExample.scala | 6 +-
.../ddata/typed/scaladsl/ReplicatorSpec.scala | 4 +-
.../typed/ActorRefIgnoreSerializationSpec.scala | 13 +-
.../pekko/cluster/typed/ActorSystemSpec.scala | 17 +-
.../cluster/typed/ClusterActorLoggingSpec.scala | 9 +-
.../pekko/cluster/typed/ClusterApiSpec.scala | 7 +-
.../typed/ClusterDispatcherSelectorSpec.scala | 4 +-
.../cluster/typed/ClusterSingletonApiSpec.scala | 7 +-
.../typed/ClusterSingletonPoisonPillSpec.scala | 4 +-
.../pekko/cluster/typed/GroupRouterSpec.scala | 14 +-
.../pekko/cluster/typed/RemoteContextAskSpec.scala | 7 +-
.../cluster/typed/RemoteDeployNotAllowedSpec.scala | 7 +-
.../pekko/cluster/typed/RemoteMessageSpec.scala | 4 +-
.../internal/PekkoClusterTypedSerializerSpec.scala | 4 +-
.../delivery/ReliableDeliverySerializerSpec.scala | 10 +-
.../receptionist/ClusterReceptionistSpec.scala | 16 +-
.../ClusterReceptionistStateSpec.scala | 6 +-
.../cluster/protobuf/msg/ClusterMessages.java | 748 +++--
.../scala/org/apache/pekko/cluster/Cluster.scala | 57 +-
.../pekko/cluster/ClusterActorRefProvider.scala | 5 +-
.../org/apache/pekko/cluster/ClusterDaemon.scala | 131 +-
.../org/apache/pekko/cluster/ClusterEvent.scala | 11 +-
.../apache/pekko/cluster/ClusterHeartbeat.scala | 19 +-
.../pekko/cluster/ClusterRemoteWatcher.scala | 1 +
.../org/apache/pekko/cluster/ClusterSettings.scala | 14 +-
.../org/apache/pekko/cluster/ConfigUtil.scala | 8 +-
.../pekko/cluster/CrossDcClusterHeartbeat.scala | 12 +-
.../org/apache/pekko/cluster/DowningProvider.scala | 4 +-
.../scala/org/apache/pekko/cluster/Gossip.scala | 3 +-
.../cluster/JoinConfigCompatCheckCluster.scala | 4 +-
.../pekko/cluster/JoinConfigCompatChecker.scala | 8 +-
.../scala/org/apache/pekko/cluster/Member.scala | 5 +-
.../org/apache/pekko/cluster/MembershipState.scala | 8 +-
.../org/apache/pekko/cluster/Reachability.scala | 6 +-
.../org/apache/pekko/cluster/SeedNodeProcess.scala | 5 +-
.../org/apache/pekko/cluster/VectorClock.scala | 6 +-
.../protobuf/ClusterMessageSerializer.scala | 26 +-
.../cluster/routing/ClusterRouterConfig.scala | 12 +-
.../apache/pekko/cluster/sbr/DowningStrategy.scala | 8 +-
.../pekko/cluster/sbr/SplitBrainResolver.scala | 2 +-
.../cluster/sbr/SplitBrainResolverSettings.scala | 12 +-
.../org/apache/pekko/cluster/AppVersionSpec.scala | 79 +
.../ClusterAccrualFailureDetectorSpec.scala | 7 +-
.../pekko/cluster/ClusterDeathWatchSpec.scala | 10 +-
.../apache/pekko/cluster/ClusterShutdownSpec.scala | 7 +-
.../ClusterWatcherNoClusterWatcheeSpec.scala | 7 +-
.../org/apache/pekko/cluster/ConvergenceSpec.scala | 4 +-
.../DeterministicOldestWhenJoiningSpec.scala | 4 +-
...henOtherHasQuarantinedThisActorSystemSpec.scala | 2 +
.../pekko/cluster/InitialHeartbeatSpec.scala | 4 +-
.../pekko/cluster/InitialMembersOfNewDcSpec.scala | 4 +-
.../apache/pekko/cluster/JoinInProgressSpec.scala | 7 +-
.../apache/pekko/cluster/JoinSeedNodeSpec.scala | 4 +-
.../pekko/cluster/LargeMessageClusterSpec.scala | 7 +-
.../cluster/LeaderDowningAllOtherNodesSpec.scala | 4 +-
.../LeaderDowningNodeThatIsUnreachableSpec.scala | 4 +-
.../apache/pekko/cluster/LeaderLeavingSpec.scala | 7 +-
.../scala/org/apache/pekko/cluster/MBeanSpec.scala | 8 +-
.../apache/pekko/cluster/MemberWeaklyUpSpec.scala | 4 +-
.../cluster/MembershipChangeListenerUpSpec.scala | 6 +-
.../pekko/cluster/MinMembersBeforeUpSpec.scala | 12 +-
.../apache/pekko/cluster/MultiDcClusterSpec.scala | 4 +-
.../cluster/MultiDcHeartbeatTakingOverSpec.scala | 12 +-
.../apache/pekko/cluster/MultiDcJoin2Spec.scala | 4 +-
.../org/apache/pekko/cluster/MultiDcJoinSpec.scala | 4 +-
.../apache/pekko/cluster/MultiDcLastNodeSpec.scala | 4 +-
.../pekko/cluster/MultiDcSplitBrainSpec.scala | 4 +-
.../pekko/cluster/MultiDcSunnyWeatherSpec.scala | 15 +-
.../pekko/cluster/MultiNodeClusterSpec.scala | 13 +-
.../org/apache/pekko/cluster/NodeChurnSpec.scala | 4 +-
.../cluster/NodeDowningAndBeingRemovedSpec.scala | 4 +-
.../apache/pekko/cluster/NodeMembershipSpec.scala | 8 +-
.../apache/pekko/cluster/QuickRestartSpec.scala | 4 +-
.../cluster/RemoteFeaturesWithClusterSpec.scala | 7 +-
.../pekko/cluster/RestartFirstSeedNodeSpec.scala | 6 +-
.../apache/pekko/cluster/RestartNode2Spec.scala | 6 +-
.../apache/pekko/cluster/RestartNode3Spec.scala | 6 +-
.../org/apache/pekko/cluster/RestartNodeSpec.scala | 8 +-
.../pekko/cluster/SharedMediaDriverSupport.scala | 3 +-
.../pekko/cluster/SingletonClusterSpec.scala | 4 +-
.../pekko/cluster/SplitBrainQuarantineSpec.scala | 5 +-
.../org/apache/pekko/cluster/SplitBrainSpec.scala | 7 +-
.../org/apache/pekko/cluster/StreamRefSpec.scala | 12 +-
.../org/apache/pekko/cluster/StressSpec.scala | 27 +-
.../apache/pekko/cluster/SunnyWeatherSpec.scala | 4 +-
.../cluster/SurviveNetworkInstabilitySpec.scala | 8 +-
.../org/apache/pekko/cluster/TransitionSpec.scala | 3 +-
.../cluster/UnreachableNodeJoinsAgainSpec.scala | 6 +-
.../ClusterConsistentHashingRouterSpec.scala | 10 +-
.../cluster/routing/ClusterRoundRobinSpec.scala | 8 +-
.../pekko/cluster/routing/UseRoleIgnoredSpec.scala | 4 +-
.../sbr/DownAllIndirectlyConnected5NodeSpec.scala | 4 +-
.../cluster/sbr/DownAllUnstable5NodeSpec.scala | 4 +-
.../cluster/sbr/IndirectlyConnected3NodeSpec.scala | 4 +-
.../cluster/sbr/IndirectlyConnected5NodeSpec.scala | 4 +-
.../pekko/cluster/sbr/LeaseMajority5NodeSpec.scala | 8 +-
.../pekko/cluster/ClusterJavaCompileTest.java | 3 +-
.../apache/pekko/cluster/ClusterConfigSpec.scala | 6 +-
.../ClusterDeathWatchNotificationSpec.scala | 6 +-
.../apache/pekko/cluster/ClusterDeployerSpec.scala | 4 +-
.../cluster/ClusterDomainEventPublisherSpec.scala | 6 +-
.../pekko/cluster/ClusterDomainEventSpec.scala | 6 +-
.../cluster/ClusterHeartbeatSenderStateSpec.scala | 10 +-
.../org/apache/pekko/cluster/ClusterLogSpec.scala | 4 +-
.../org/apache/pekko/cluster/ClusterSpec.scala | 8 +-
.../org/apache/pekko/cluster/ClusterTestKit.scala | 17 +-
.../org/apache/pekko/cluster/ConfigUtilSpec.scala | 4 +-
.../pekko/cluster/CrossDcHeartbeatSenderSpec.scala | 2 +-
.../apache/pekko/cluster/DowningProviderSpec.scala | 17 +-
.../pekko/cluster/FailureDetectorPuppet.scala | 8 +-
.../org/apache/pekko/cluster/GossipSpec.scala | 6 +-
.../pekko/cluster/GossipTargetSelectorSpec.scala | 6 +-
.../pekko/cluster/HeartbeatNodeRingPerfSpec.scala | 4 +-
.../pekko/cluster/HeartbeatNodeRingSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckClusterSpec.scala | 6 +-
.../JoinConfigCompatCheckerRollingUpdateSpec.scala | 4 +-
.../cluster/JoinConfigCompatCheckerSpec.scala | 35 +-
.../JoinConfigCompatPreDefinedChecksSpec.scala | 3 +-
.../apache/pekko/cluster/MemberOrderingSpec.scala | 6 +-
.../apache/pekko/cluster/MembershipStateSpec.scala | 6 +-
.../pekko/cluster/MixedProtocolClusterSpec.scala | 173 +-
.../pekko/cluster/ReachabilityPerfSpec.scala | 24 +-
.../apache/pekko/cluster/ReachabilitySpec.scala | 4 +-
.../pekko/cluster/StartupWithOneThreadSpec.scala | 17 +-
.../apache/pekko/cluster/VectorClockPerfSpec.scala | 12 +-
.../protobuf/ClusterMessageSerializerSpec.scala | 7 +-
.../pekko/cluster/sbr/LeaseMajoritySpec.scala | 4 +-
.../pekko/cluster/sbr/SplitBrainResolverSpec.scala | 32 +-
.../coordination/lease/LeaseUsageSettings.scala | 4 +-
.../pekko/coordination/lease/TimeoutSettings.scala | 21 +-
.../coordination/lease/internal/LeaseAdapter.scala | 4 +-
.../coordination/lease/javadsl/LeaseProvider.scala | 3 +
.../lease/scaladsl/LeaseProvider.scala | 2 +-
.../lease/javadsl/LeaseProviderTest.java | 18 +-
.../pekko/coordination/lease/TestLease.scala | 6 +-
.../coordination/lease/TimeoutSettingsSpec.scala | 3 +-
.../lease/scaladsl/LeaseProviderSpec.scala | 4 +-
discovery/src/main/resources/reference.conf | 5 +-
.../apache/pekko/discovery/ServiceDiscovery.scala | 30 +-
.../aggregate/AggregateServiceDiscovery.scala | 6 +-
.../discovery/config/ConfigServiceDiscovery.scala | 6 +-
.../discovery/DiscoveryConfigurationSpec.scala | 9 +-
.../aggregate/AggregateServiceDiscoverySpec.scala | 17 +-
.../config/ConfigServiceDiscoverySpec.scala | 12 +-
.../config/ConfigServicesParserSpec.scala | 9 +-
.../pekko/discovery/dns/DnsDiscoverySpec.scala | 6 +-
.../discovery/dns/DnsServiceDiscoverySpec.scala | 8 +-
.../ddata/protobuf/msg/ReplicatedDataMessages.java | 685 +++--
.../ddata/protobuf/msg/ReplicatorMessages.java | 1087 +++++--
.../2.0.x.backwards.excludes/crdt-expiry.excludes | 34 +
.../src/main/protobuf/ReplicatorMessages.proto | 2 +
distributed-data/src/main/resources/reference.conf | 10 +
.../org/apache/pekko/cluster/ddata/GSet.scala | 7 +-
.../org/apache/pekko/cluster/ddata/GSet.scala | 8 +-
.../cluster/ddata/DeltaPropagationSelector.scala | 2 -
.../apache/pekko/cluster/ddata/DurableStore.scala | 72 +-
.../org/apache/pekko/cluster/ddata/Flag.scala | 5 +-
.../org/apache/pekko/cluster/ddata/GCounter.scala | 5 +-
.../scala/org/apache/pekko/cluster/ddata/Key.scala | 11 +-
.../org/apache/pekko/cluster/ddata/LWWMap.scala | 9 +-
.../apache/pekko/cluster/ddata/LWWRegister.scala | 7 +-
.../org/apache/pekko/cluster/ddata/ORMap.scala | 59 +-
.../apache/pekko/cluster/ddata/ORMultiMap.scala | 11 +-
.../org/apache/pekko/cluster/ddata/ORSet.scala | 40 +-
.../org/apache/pekko/cluster/ddata/PNCounter.scala | 5 +-
.../apache/pekko/cluster/ddata/PNCounterMap.scala | 9 +-
.../apache/pekko/cluster/ddata/PruningState.scala | 5 +-
.../pekko/cluster/ddata/ReplicatedData.scala | 3 +-
.../apache/pekko/cluster/ddata/Replicator.scala | 451 ++-
.../ddata/protobuf/ReplicatedDataSerializer.scala | 147 +-
.../protobuf/ReplicatorMessageSerializer.scala | 85 +-
.../ddata/protobuf/SerializationSupport.scala | 22 +-
.../pekko/cluster/ddata/DurableDataSpec.scala | 9 +-
.../pekko/cluster/ddata/DurablePruningSpec.scala | 9 +-
.../cluster/ddata/JepsenInspiredInsertSpec.scala | 20 +-
.../pekko/cluster/ddata/PerformanceSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorChaosSpec.scala | 10 +-
.../pekko/cluster/ddata/ReplicatorDeltaSpec.scala | 28 +-
.../pekko/cluster/ddata/ReplicatorGossipSpec.scala | 8 +-
.../cluster/ddata/ReplicatorMapDeltaSpec.scala | 4 +-
.../cluster/ddata/ReplicatorORSetDeltaSpec.scala | 6 +-
.../cluster/ddata/ReplicatorPruningSpec.scala | 4 +-
.../pekko/cluster/ddata/ReplicatorSpec.scala | 16 +-
.../pekko/cluster/ddata/STMultiNodeSpec.scala | 4 +-
.../cluster/ddata/WildcardSubscribeSpec.scala | 215 ++
.../pekko/cluster/ddata/DataEnvelopeSpec.scala | 6 +-
.../ddata/DeltaPropagationSelectorSpec.scala | 5 +-
.../org/apache/pekko/cluster/ddata/FlagSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/GCounterSpec.scala | 6 +-
.../org/apache/pekko/cluster/ddata/GSetSpec.scala | 4 +-
.../apache/pekko/cluster/ddata/LWWMapSpec.scala | 6 +-
.../pekko/cluster/ddata/LWWRegisterSpec.scala | 6 +-
.../pekko/cluster/ddata/LocalConcurrencySpec.scala | 13 +-
.../apache/pekko/cluster/ddata/LotsOfDataBot.scala | 6 +-
.../org/apache/pekko/cluster/ddata/ORMapSpec.scala | 6 +-
.../pekko/cluster/ddata/ORMultiMapSpec.scala | 6 +-
.../org/apache/pekko/cluster/ddata/ORSetSpec.scala | 6 +-
.../pekko/cluster/ddata/PNCounterMapSpec.scala | 6 +-
.../apache/pekko/cluster/ddata/PNCounterSpec.scala | 6 +-
.../pekko/cluster/ddata/PruningStateSpec.scala | 6 +-
.../cluster/ddata/ReplicatorSettingsSpec.scala | 21 +-
.../ddata/ReplicatorWildcardSubscriptionSpec.scala | 130 +
.../pekko/cluster/ddata/VersionVectorSpec.scala | 8 +-
.../pekko/cluster/ddata/WriteAggregatorSpec.scala | 2 +-
.../protobuf/ReplicatedDataSerializerSpec.scala | 25 +-
.../protobuf/ReplicatorMessageSerializerSpec.scala | 39 +-
.../ddata/protobuf/msg/TwoPhaseSetMessages.java | 68 +-
.../docs/persistence/proto/FlightAppModels.java | 39 +-
.../docs/persistence/state/MyJavaStateStore.java | 78 +
.../state/MyJavaStateStoreProvider.java | 45 +
docs/src/main/paradox/actors.md | 5 +-
docs/src/main/paradox/additional/deploying.md | 6 +-
docs/src/main/paradox/additional/ide.md | 2 +-
docs/src/main/paradox/additional/operations.md | 2 +-
docs/src/main/paradox/additional/osgi.md | 4 +-
docs/src/main/paradox/cluster-usage.md | 2 +-
.../paradox/common/binary-compatibility-rules.md | 2 +-
docs/src/main/paradox/common/other-modules.md | 2 +-
docs/src/main/paradox/discovery/index.md | 2 +-
docs/src/main/paradox/dispatchers.md | 18 +-
.../paradox/durable-state/state-store-plugin.md | 45 +
docs/src/main/paradox/extending-pekko.md | 2 +-
docs/src/main/paradox/fsm.md | 5 +-
docs/src/main/paradox/futures.md | 2 +-
docs/src/main/paradox/general/configuration.md | 2 +-
.../general/message-delivery-reliability.md | 4 +-
docs/src/main/paradox/general/remoting.md | 12 +-
...ode.png => dispatcher-behavior-on-bad-code.png} | Bin
...de.png => dispatcher-behavior-on-good-code.png} | Bin
docs/src/main/paradox/index.md | 2 +-
docs/src/main/paradox/io-dns.md | 2 +-
docs/src/main/paradox/persistence-journals.md | 12 +-
docs/src/main/paradox/persistence-query.md | 11 +-
docs/src/main/paradox/persistence.md | 6 +
.../paradox/project/{project-index.md => index.md} | 2 +-
docs/src/main/paradox/release-notes/index.md | 5 +
.../src/main/paradox/release-notes/releases-1.2.md | 23 +
.../src/main/paradox/release-notes/releases-1.3.md | 57 +
.../src/main/paradox/release-notes/releases-1.4.md | 16 +
.../src/main/paradox/release-notes/releases-1.5.md | 31 +
.../src/main/paradox/release-notes/releases-1.6.md | 12 +
.../src/main/paradox/release-notes/releases-2.0.md | 49 +
docs/src/main/paradox/remote-security.md | 426 +++
docs/src/main/paradox/remoting-artery.md | 202 +-
docs/src/main/paradox/remoting.md | 2 +-
docs/src/main/paradox/security/index.md | 2 +-
docs/src/main/paradox/serialization-jackson.md | 12 +-
docs/src/main/paradox/serialization.md | 4 +-
docs/src/main/paradox/split-brain-resolver.md | 2 +-
.../Compression/{gunzip.md => gzipDecompress.md} | 4 +-
.../main/paradox/stream/operators/Flow/lazyFlow.md | 2 +-
.../paradox/stream/operators/Sink/asPublisher.md | 3 +-
.../stream/operators/Sink/completionStageSink.md | 8 +
.../main/paradox/stream/operators/Sink/count.md | 39 +
.../operators/Sink/eagerCompletionStageSink.md | 33 +
.../stream/operators/Sink/eagerFutureSink.md | 37 +
.../stream/operators/Sink/fromSubscriber.md | 4 +-
.../paradox/stream/operators/Sink/futureSink.md | 6 +
.../operators/Sink/lazyCompletionStageSink.md | 5 +-
.../stream/operators/Sink/lazyFutureSink.md | 4 +-
.../stream/operators/Sink/preMaterialize.md | 3 +
.../main/paradox/stream/operators/Sink/source.md | 29 +
.../Source-or-Flow/aggregateWithBoundary.md | 4 +
.../stream/operators/Source-or-Flow/alsoTo.md | 11 +-
.../stream/operators/Source-or-Flow/alsoToAll.md | 2 +-
.../stream/operators/Source-or-Flow/batch.md | 5 +
.../operators/Source-or-Flow/batchWeighted.md | 5 +
.../stream/operators/Source-or-Flow/collect.md | 2 +-
.../stream/operators/Source-or-Flow/collectType.md | 2 +-
.../stream/operators/Source-or-Flow/delayWith.md | 2 +
.../stream/operators/Source-or-Flow/doOnCancel.md | 28 +
.../stream/operators/Source-or-Flow/doOnFirst.md | 33 +
.../stream/operators/Source-or-Flow/expand.md | 8 +-
.../stream/operators/Source-or-Flow/extrapolate.md | 6 +
.../operators/Source-or-Flow/groupedAdjacentBy.md | 2 +
.../Source-or-Flow/groupedAdjacentByWeighted.md | 4 +-
.../Source-or-Flow/groupedWeightedWithin.md | 1 +
.../operators/Source-or-Flow/mapAsyncUnordered.md | 10 +-
.../stream/operators/Source-or-Flow/mapOption.md | 31 +
.../operators/Source-or-Flow/onErrorContinue.md | 27 +
.../operators/Source-or-Flow/preMaterialize.md | 4 +
.../stream/operators/Source-or-Flow/throttle.md | 2 +
.../stream/operators/Source-or-Flow/zipWith.md | 4 +
.../stream/operators/Source/asSubscriber.md | 25 +-
.../paradox/stream/operators/Source/fromArray.md | 2 +-
.../paradox/stream/operators/Source/fromOption.md | 26 +
.../stream/operators/Source/fromPublisher.md | 19 +-
.../main/paradox/stream/operators/Source/items.md | 26 +
.../main/paradox/stream/operators/Source/never.md | 2 +-
.../paradox/stream/operators/Source/zipWithN.md | 5 +-
.../operators/StreamConverters/javaCollector.md | 25 +-
docs/src/main/paradox/stream/operators/index.md | 30 +-
.../paradox/stream/reactive-streams-interop.md | 2 +-
docs/src/main/paradox/stream/stream-context.md | 13 +-
docs/src/main/paradox/stream/stream-customize.md | 6 +-
docs/src/main/paradox/stream/stream-graphs.md | 8 +-
docs/src/main/paradox/stream/stream-quickstart.md | 4 +-
docs/src/main/paradox/stream/stream-refs.md | 2 +-
docs/src/main/paradox/typed/actor-lifecycle.md | 2 +-
docs/src/main/paradox/typed/actors.md | 24 +-
docs/src/main/paradox/typed/choosing-cluster.md | 4 +-
.../typed/cluster-sharded-daemon-process.md | 38 +-
docs/src/main/paradox/typed/cluster-sharding.md | 51 +-
docs/src/main/paradox/typed/cluster-singleton.md | 6 +-
docs/src/main/paradox/typed/cluster.md | 2 +-
docs/src/main/paradox/typed/dispatchers.md | 26 +-
docs/src/main/paradox/typed/distributed-data.md | 14 +-
docs/src/main/paradox/typed/distributed-pub-sub.md | 14 +-
.../paradox/typed/durable-state/persistence.md | 7 +
docs/src/main/paradox/typed/extending.md | 2 +-
docs/src/main/paradox/typed/fault-tolerance.md | 2 +-
docs/src/main/paradox/typed/index-cluster.md | 1 +
.../typed/index-persistence-durable-state.md | 1 +
.../src/main/paradox/typed/interaction-patterns.md | 4 +-
.../src/main/paradox/typed/persistence-snapshot.md | 4 +-
docs/src/main/paradox/typed/persistence-testing.md | 44 +-
docs/src/main/paradox/typed/persistence.md | 12 +-
.../main/paradox/typed/replicated-eventsourcing.md | 2 +-
docs/src/main/paradox/typed/style-guide.md | 5 +-
docs/src/main/paradox/typed/testing-sync.md | 12 +-
.../docs/persistence/state/MyStateStore.scala | 71 +
docs/src/test/java/jdocs/AbstractJavaTest.java | 4 +-
docs/src/test/java/jdocs/actor/ActorDocTest.java | 36 +-
.../jdocs/actor/ByteBufferSerializerDocTest.java | 1 +
.../jdocs/actor/DependencyInjectionDocTest.java | 12 +-
.../java/jdocs/actor/FaultHandlingDocSample.java | 14 +-
.../test/java/jdocs/actor/FaultHandlingTest.java | 12 +-
.../test/java/jdocs/actor/ImmutableMessage.java | 20 +-
.../java/jdocs/actor/InitializationDocTest.java | 10 +-
docs/src/test/java/jdocs/actor/Messages.java | 20 +-
.../src/test/java/jdocs/actor/SampleActorTest.java | 12 +-
.../test/java/jdocs/actor/SchedulerDocTest.java | 11 +-
docs/src/test/java/jdocs/actor/fsm/Buncher.java | 4 +-
.../src/test/java/jdocs/actor/fsm/BuncherTest.java | 10 +-
docs/src/test/java/jdocs/actor/fsm/FSMDocTest.java | 12 +-
.../actor/typed/CoordinatedActorShutdownTest.java | 1 +
.../test/java/jdocs/cluster/ClusterDocTest.java | 10 +-
.../test/java/jdocs/cluster/FactorialFrontend.java | 9 +-
.../src/test/java/jdocs/cluster/StatsMessages.java | 36 +-
docs/src/test/java/jdocs/cluster/StatsService.java | 14 +-
.../java/jdocs/cluster/TransformationBackend.java | 2 +-
.../java/jdocs/cluster/TransformationMessages.java | 42 +-
.../singleton/ClusterSingletonSupervision.java | 1 +
.../test/java/jdocs/coordination/LeaseDocTest.java | 13 +-
.../java/jdocs/ddata/DistributedDataDocTest.java | 16 +-
docs/src/test/java/jdocs/ddata/ShoppingCart.java | 81 +-
.../java/jdocs/discovery/DnsDiscoveryDocTest.java | 13 +-
.../java/jdocs/dispatcher/DispatcherDocTest.java | 15 +-
docs/src/test/java/jdocs/duration/Java.java | 2 +-
.../src/test/java/jdocs/event/EventBusDocTest.java | 16 +-
docs/src/test/java/jdocs/event/LoggingDocTest.java | 5 +-
.../java/jdocs/extension/ExtensionDocTest.java | 2 +-
.../jdocs/extension/SettingsExtensionDocTest.java | 3 +-
docs/src/test/java/jdocs/future/FutureDocTest.java | 94 +-
docs/src/test/java/jdocs/io/JavaUdpMulticast.java | 3 +-
.../test/java/jdocs/io/JavaUdpMulticastTest.java | 10 +-
.../test/java/jdocs/io/UdpConnectedDocTest.java | 3 +-
docs/src/test/java/jdocs/io/japi/EchoHandler.java | 4 +-
docs/src/test/java/jdocs/io/japi/IODocTest.java | 19 +-
docs/src/test/java/jdocs/io/japi/Message.java | 18 +-
.../persistence/LambdaPersistenceDocTest.java | 32 +-
.../LambdaPersistencePluginDocTest.java | 31 +-
.../persistence/testkit/PersistenceInitTest.java | 35 +-
.../PersistenceTestKitPolicySampleTest.java | 28 +-
.../testkit/PersistenceTestKitSampleTest.java | 28 +-
.../jdocs/remoting/RemoteDeploymentDocTest.java | 14 +-
.../routing/ConsistentHashingRouterDocTest.java | 14 +-
.../java/jdocs/routing/CustomRouterDocTest.java | 15 +-
.../src/test/java/jdocs/routing/RouterDocTest.java | 19 +-
.../jdocs/serialization/SerializationDocTest.java | 6 +-
.../java/jdocs/sharding/ClusterShardingTest.java | 12 +-
.../test/java/jdocs/stream/BidiFlowDocTest.java | 30 +-
.../test/java/jdocs/stream/CompositionDocTest.java | 14 +-
docs/src/test/java/jdocs/stream/FlowDocTest.java | 31 +-
.../test/java/jdocs/stream/FlowErrorDocTest.java | 63 +-
.../java/jdocs/stream/FlowParallelismDocTest.java | 10 +-
.../java/jdocs/stream/FlowStreamRefsDocTest.java | 2 +-
.../test/java/jdocs/stream/GraphCyclesDocTest.java | 14 +-
.../test/java/jdocs/stream/GraphStageDocTest.java | 32 +-
.../jdocs/stream/GraphStageLoggingDocTest.java | 2 +-
docs/src/test/java/jdocs/stream/HubDocTest.java | 10 +-
.../test/java/jdocs/stream/IntegrationDocTest.java | 25 +-
.../test/java/jdocs/stream/KillSwitchDocTest.java | 22 +-
.../test/java/jdocs/stream/QuickStartDocTest.java | 4 +-
.../jdocs/stream/RateTransformationDocTest.java | 43 +-
.../java/jdocs/stream/ReactiveStreamsDocTest.java | 10 +-
.../test/java/jdocs/stream/SinkRecipeDocTest.java | 6 +-
.../jdocs/stream/StreamBuffersRateDocTest.java | 14 +-
.../jdocs/stream/StreamPartialGraphDSLDocTest.java | 18 +-
.../java/jdocs/stream/StreamTestKitDocTest.java | 36 +-
.../test/java/jdocs/stream/SubstreamDocTest.java | 42 +-
.../stream/TwitterStreamQuickstartDocTest.java | 18 +-
.../java/jdocs/stream/io/StreamFileDocTest.java | 10 +-
.../java/jdocs/stream/io/StreamTcpDocTest.java | 10 +-
.../javadsl/cookbook/RecipeAdhocSourceTest.java | 36 +-
.../stream/javadsl/cookbook/RecipeByteStrings.java | 25 +-
.../stream/javadsl/cookbook/RecipeDecompress.java | 16 +-
.../stream/javadsl/cookbook/RecipeDigest.java | 12 +-
.../javadsl/cookbook/RecipeDroppyBroadcast.java | 10 +-
.../stream/javadsl/cookbook/RecipeFlattenList.java | 17 +-
.../javadsl/cookbook/RecipeGlobalRateLimit.java | 14 +-
.../jdocs/stream/javadsl/cookbook/RecipeHold.java | 18 +-
.../stream/javadsl/cookbook/RecipeKeepAlive.java | 10 +-
.../javadsl/cookbook/RecipeLoggingElements.java | 18 +-
.../javadsl/cookbook/RecipeManualTrigger.java | 24 +-
.../stream/javadsl/cookbook/RecipeMissedTicks.java | 14 +-
.../javadsl/cookbook/RecipeMultiGroupByTest.java | 23 +-
.../stream/javadsl/cookbook/RecipeParseLines.java | 14 +-
.../javadsl/cookbook/RecipeReduceByKeyTest.java | 21 +-
.../jdocs/stream/javadsl/cookbook/RecipeSeq.java | 17 +-
.../stream/javadsl/cookbook/RecipeSimpleDrop.java | 14 +-
.../javadsl/cookbook/RecipeSourceFromFunction.java | 14 +-
.../stream/javadsl/cookbook/RecipeSplitter.java | 23 +-
.../stream/javadsl/cookbook/RecipeWorkerPool.java | 15 +-
.../stream/operators/BroadcastDocExample.java | 1 +
.../DiMap.java => JavaCollectorDocExamples.java} | 33 +-
.../stream/operators/MergeSequenceDocExample.java | 1 +
.../stream/operators/PartitionDocExample.java | 1 +
.../jdocs/stream/operators/SinkDocExamples.java | 19 +-
.../jdocs/stream/operators/SourceDocExamples.java | 6 +-
.../java/jdocs/stream/operators/SourceOrFlow.java | 139 +-
.../jdocs/stream/operators/WithContextTest.java | 42 +-
.../converters/StreamConvertersToJava.java | 12 +-
.../operators/converters/ToFromJavaIOStreams.java | 14 +-
.../java/jdocs/stream/operators/flow/DiMap.java | 4 +-
.../jdocs/stream/operators/flow/StatefulMap.java | 12 +-
.../stream/operators/flow/StatefulMapConcat.java | 20 +-
.../stream/operators/source/AsSubscriber.java | 4 +-
.../jdocs/stream/operators/source/Combine.java | 6 +-
.../java/jdocs/stream/operators/source/From.java | 5 +-
.../stream/operators/source/FromPublisher.java | 2 +-
.../java/jdocs/stream/operators/source/Zip.java | 21 +-
.../operators/sourceorflow/FlatMapConcat.java | 6 +-
.../operators/sourceorflow/FlatMapMerge.java | 6 +-
.../stream/operators/sourceorflow/Intersperse.java | 4 +-
.../stream/operators/sourceorflow/MapConcat.java | 6 +-
.../stream/operators/sourceorflow/MapError.java | 4 +-
.../operators/sourceorflow/MapWithResource.java | 3 +-
.../stream/operators/sourceorflow/MergeLatest.java | 6 +-
.../stream/operators/sourceorflow/Monitor.java | 4 +-
.../stream/operators/sourceorflow/Sliding.java | 4 +-
.../jdocs/stream/operators/sourceorflow/Split.java | 4 +-
.../test/java/jdocs/testkit/ParentChildTest.java | 12 +-
.../test/java/jdocs/testkit/TestKitDocTest.java | 22 +-
.../test/java/jdocs/testkit/TestKitSampleTest.java | 14 +-
.../tutorial_1/ActorHierarchyExperiments.java | 4 +
.../java/jdocs/typed/tutorial_3/DeviceTest.java | 20 +-
.../jdocs/typed/tutorial_4/DeviceGroupTest.java | 19 +-
.../jdocs/typed/tutorial_4/DeviceManagerTest.java | 17 +-
.../java/jdocs/typed/tutorial_4/DeviceTest.java | 17 +-
.../jdocs/typed/tutorial_5/DeviceGroupQuery.java | 9 +-
.../typed/tutorial_5/DeviceGroupQueryTest.java | 17 +-
.../jdocs/typed/tutorial_5/DeviceGroupTest.java | 19 +-
.../jdocs/typed/tutorial_5/DeviceManagerTest.java | 17 +-
.../java/jdocs/typed/tutorial_5/DeviceTest.java | 17 +-
docs/src/test/scala/docs/actor/ActorDocSpec.scala | 26 +-
.../scala/docs/actor/FaultHandlingDocSample.scala | 38 +-
.../docs/actor/SharedMutableStateDocSpec.scala | 2 +-
.../docs/actor/io/dns/DnsCompileOnlyDocSpec.scala | 25 +-
.../test/scala/docs/cluster/FactorialBackend.scala | 2 +-
.../scala/docs/ddata/DistributedDataDocSpec.scala | 12 +-
docs/src/test/scala/docs/ddata/ShoppingCart.scala | 4 +-
.../ddata/protobuf/TwoPhaseSetSerializer.scala | 6 +-
.../ddata/protobuf/TwoPhaseSetSerializer2.scala | 2 +-
.../src/test/scala/docs/event/LoggingDocSpec.scala | 2 +-
.../src/test/scala/docs/future/FutureDocSpec.scala | 2 +-
docs/src/test/scala/docs/io/EchoServer.scala | 28 +-
docs/src/test/scala/docs/io/ReadBackPressure.scala | 2 +-
.../src/test/scala/docs/io/ScalaUdpMulticast.scala | 3 +-
.../test/scala/docs/io/ScalaUdpMulticastSpec.scala | 2 +-
.../persistence/PersistencePluginDocSpec.scala | 51 +-
.../persistence/PersistenceSerializerDocSpec.scala | 4 +-
.../docs/persistence/PersistentActorExample.scala | 22 +-
.../query/PersistenceQueryDocSpec.scala | 2 +-
.../state/PersistenceStatePluginDocSpec.scala | 83 +
.../test/scala/docs/routing/RouterDocSpec.scala | 2 +-
.../docs/serialization/SerializationDocSpec.scala | 2 +-
.../test/scala/docs/stream/GraphDSLDocSpec.scala | 4 +-
.../scala/docs/stream/IntegrationDocSpec.scala | 2 +-
.../test/scala/docs/stream/QuickStartDocSpec.scala | 8 +-
.../docs/stream/RateTransformationDocSpec.scala | 8 +-
.../scala/docs/stream/StreamTestKitDocSpec.scala | 6 +-
.../test/scala/docs/stream/SubstreamDocSpec.scala | 5 +-
.../stream/TwitterStreamQuickstartDocSpec.scala | 11 +-
.../docs/stream/cookbook/RecipeAdhocSource.scala | 10 +-
.../docs/stream/cookbook/RecipeDecompress.scala | 2 +-
.../scala/docs/stream/operators/DoOnFirst.scala | 28 +-
.../stream/operators/JavaCollectorDocExample.scala | 31 +-
.../scala/docs/stream/operators/MapOption.scala | 29 +
.../docs/stream/operators/WithContextSpec.scala | 25 +
.../docs/stream/operators/flow/FutureFlow.scala | 1 +
.../stream/operators/source/AsSubscriber.scala | 2 +-
.../docs/stream/operators/source/Restart.scala | 112 +-
.../scala/docs/stream/operators/source/Zip.scala | 2 +-
.../sourceorflow/ExtrapolateAndExpand.scala | 8 +-
.../docs/stream/operators/sourceorflow/Fold.scala | 34 +-
.../stream/operators/sourceorflow/FoldAsync.scala | 24 +-
.../stream/operators/sourceorflow/FoldWhile.scala | 20 +-
.../stream/operators/sourceorflow/GroupBy.scala | 7 +-
.../operators/sourceorflow/Intersperse.scala | 20 +-
.../docs/stream/operators/sourceorflow/Limit.scala | 2 +-
.../operators/sourceorflow/LimitWeighted.scala | 2 +-
.../stream/operators/sourceorflow/MapAsyncs.scala | 78 +-
.../stream/operators/sourceorflow/MapError.scala | 44 +-
.../operators/sourceorflow/MergeLatest.scala | 42 +-
.../stream/operators/sourceorflow/Throttle.scala | 56 +-
.../operators/sourceorflow/WatchTermination.scala | 4 +-
.../test/scala/docs/testkit/TestKitUsageSpec.scala | 2 +-
.../tutorial_1/ActorHierarchyExperiments.scala | 8 +-
legal/PekkoNotice.txt | 2 +-
legal/pekko-actor-jar-license.txt | 26 +-
legal/pekko-actor-jar-notice.txt | 15 +-
legal/pekko-remote-jar-notice.txt | 2 +-
.../testconductor/TestConductorProtocol.java | 208 +-
.../pekko/remote/testconductor/Conductor.scala | 13 +-
.../pekko/remote/testconductor/DataTypes.scala | 6 +-
.../pekko/remote/testconductor/Extension.scala | 4 +-
.../apache/pekko/remote/testconductor/Player.scala | 19 +-
.../remote/testconductor/RemoteConnection.scala | 8 +-
.../pekko/remote/testkit/MultiNodeSpec.scala | 19 +-
.../pekko/remote/testkit/PerfFlamesSupport.scala | 4 +-
.../apache/pekko/osgi/ActorSystemActivator.scala | 14 +-
.../pekko/osgi/BundleDelegatingClassLoader.scala | 7 +-
.../apache/pekko/osgi/OsgiActorSystemFactory.scala | 8 +-
.../pekko/osgi/ActorSystemActivatorTest.scala | 5 +-
.../org/apache/pekko/osgi/PojoSRTestSupport.scala | 6 +-
.../query/internal/protobuf/QueryMessages.java | 607 +++-
.../persistence/query/javadsl/package-info.java | 15 +-
.../typed-event-envelope-tags.excludes | 27 +
.../src/main/protobuf/QueryMessages.proto | 3 +
.../src/main/resources/reference.conf | 53 +
.../pekko/persistence/query/EventEnvelope.scala | 12 +-
.../apache/pekko/persistence/query/Offset.scala | 2 +-
.../pekko/persistence/query/PersistenceQuery.scala | 8 +-
.../persistence/query/ReadJournalProvider.scala | 4 +-
.../query/internal/QuerySerializer.scala | 30 +-
.../query/javadsl/DurableStateStoreQuery.scala | 2 +-
.../journal/leveldb/AllPersistenceIdsStage.scala | 2 +-
.../persistence/query/journal/leveldb/Buffer.scala | 3 +-
.../leveldb/EventsByPersistenceIdStage.scala | 6 +-
.../query/journal/leveldb/EventsByTagStage.scala | 3 +-
.../leveldb/LeveldbReadJournalProvider.scala | 3 +-
.../leveldb/javadsl/LeveldbReadJournal.scala | 4 +-
.../leveldb/scaladsl/LeveldbReadJournal.scala | 17 +-
.../query/scaladsl/DurableStateStoreQuery.scala | 2 +-
.../persistence/query/typed/EventEnvelope.scala | 166 +-
.../EventsBySliceFirehoseReadJournalProvider.scala | 33 +
.../typed/internal/EventsBySliceFirehose.scala | 839 ++++++
...sByPersistenceIdStartingFromSnapshotQuery.scala | 39 +
.../CurrentEventsByPersistenceIdTypedQuery.scala | 41 +
...ntEventsBySliceStartingFromSnapshotsQuery.scala | 52 +
...sByPersistenceIdStartingFromSnapshotQuery.scala | 39 +
.../javadsl/EventsByPersistenceIdTypedQuery.scala | 48 +
.../typed/javadsl/EventsBySliceFirehoseQuery.scala | 95 +
.../query/typed/javadsl/EventsBySliceQuery.scala | 2 +
.../EventsBySliceStartingFromSnapshotsQuery.scala | 54 +
...sByPersistenceIdStartingFromSnapshotQuery.scala | 39 +
.../CurrentEventsByPersistenceIdTypedQuery.scala | 41 +
...ntEventsBySliceStartingFromSnapshotsQuery.scala | 53 +
...sByPersistenceIdStartingFromSnapshotQuery.scala | 39 +
.../scaladsl/EventsByPersistenceIdTypedQuery.scala | 48 +
.../scaladsl/EventsBySliceFirehoseQuery.scala | 119 +
.../query/typed/scaladsl/EventsBySliceQuery.scala | 2 +
.../EventsBySliceStartingFromSnapshotsQuery.scala | 55 +
.../persistence/query/PersistenceQueryTest.java | 10 +-
.../pekko/persistence/query/DummyReadJournal.scala | 18 +-
.../persistence/query/PersistenceQuerySpec.scala | 12 +-
.../apache/pekko/persistence/query/TestClock.scala | 59 +
.../query/internal/QuerySerializerSpec.scala | 34 +-
.../journal/leveldb/AllPersistenceIdsSpec.scala | 10 +-
.../leveldb/EventsByPersistenceIdSpec.scala | 38 +-
.../query/journal/leveldb/EventsByTagSpec.scala | 26 +-
.../query/typed/EventEnvelopeSpec.scala | 53 +
.../typed/internal/EventsBySliceFirehoseSpec.scala | 440 +++
.../leveldb/PersistencePluginProxySpec.scala | 4 +-
.../journal/leveldb/SharedLeveldbJournalSpec.scala | 4 +-
.../persistence/serialization/SerializerSpec.scala | 15 +-
.../apache/pekko/persistence/CapabilityFlags.scala | 40 +
.../org/apache/pekko/persistence/PluginSpec.scala | 9 +-
.../apache/pekko/persistence/TestSerializer.scala | 4 +-
.../japi/journal/JavaJournalPerfSpec.scala | 10 +-
.../persistence/japi/journal/JavaJournalSpec.scala | 4 +-
.../japi/snapshot/JavaSnapshotStoreSpec.scala | 4 +-
.../JavaDurableStateStoreSpec.scala} | 27 +-
.../persistence/journal/JournalPerfSpec.scala | 8 +-
.../pekko/persistence/journal/JournalSpec.scala | 62 +-
.../pekko/persistence/scalatest/MayVerb.scala | 3 +-
.../persistence/scalatest/OptionalTests.scala | 9 +-
.../persistence/snapshot/SnapshotStoreSpec.scala | 6 +-
.../persistence/state/DurableStateStoreSpec.scala | 216 ++
.../apache/pekko/persistence/PluginCleanup.scala | 1 +
.../persistence/japi/JavaJournalSpecSpec.scala | 5 +-
.../journal/inmem/InmemJournalSpec.scala | 1 +
.../journal/leveldb/LeveldbJournalJavaSpec.scala | 3 +
.../journal/leveldb/LeveldbJournalNativeSpec.scala | 2 +
...bJournalNoAtomicPersistMultipleEventsSpec.scala | 2 +
.../snapshot/local/LocalSnapshotStoreSpec.scala | 4 +-
.../persistence/testkit/javadsl/package-info.java | 15 +-
.../pekko/persistence/testkit/EventStorage.scala | 6 +-
.../testkit/PersistenceTestKitPlugin.scala | 26 +-
.../persistence/testkit/ProcessingPolicy.scala | 4 +-
.../persistence/testkit/SnapshotStorage.scala | 3 -
.../internal/EventSourcedBehaviorTestKitImpl.scala | 7 +-
.../testkit/internal/InMemStorageExtension.scala | 2 +-
.../testkit/internal/PersistenceProbeImpl.scala | 488 ++++
.../SnapshotStorageEmulatorExtension.scala | 4 +-
.../testkit/internal/TestKitStorage.scala | 4 +-
.../javadsl/EventSourcedBehaviorTestKit.scala | 33 +-
.../testkit/javadsl/PersistenceInit.scala | 7 +-
.../testkit/javadsl/PersistenceProbeBehavior.scala | 164 ++
.../testkit/javadsl/PersistenceTestKit.scala | 15 +-
.../testkit/javadsl/SnapshotTestKit.scala | 15 +-
.../PersistenceTestKitReadJournalProvider.scala | 1 +
.../query/internal/EventsBySliceStage.scala | 8 +-
.../testkit/query/internal/EventsByTagStage.scala | 6 +-
.../internal/TypedEventsByPersistenceIdStage.scala | 116 +
.../javadsl/PersistenceTestKitReadJournal.scala | 25 +-
.../scaladsl/PersistenceTestKitReadJournal.scala | 94 +-
.../scaladsl/EventSourcedBehaviorTestKit.scala | 10 +-
.../scaladsl/PersistenceProbeBehavior.scala | 144 +
.../testkit/scaladsl/PersistenceTestKit.scala | 6 +-
.../persistence/testkit/scaladsl/TestOps.scala | 20 +-
...rsistenceTestKitDurableStateStoreProvider.scala | 4 +-
.../PersistenceTestKitDurableStateStore.scala | 10 +-
.../PersistenceTestKitDurableStateStore.scala | 14 +-
.../pekko/persistence/testkit/CommonUtils.scala | 9 +-
.../testkit/javadsl/CommonSnapshotTests.scala | 5 +-
.../testkit/javadsl/CommonTestKitTests.scala | 5 +-
.../testkit/query/CurrentEventsBySlicesSpec.scala | 34 +-
.../testkit/query/CurrentEventsByTagSpec.scala | 5 +-
.../testkit/query/EventsByPersistenceIdSpec.scala | 43 +-
.../query/EventsByPersistenceIdTypedSpec.scala | 114 +
.../testkit/query/EventsBySliceSpec.scala | 30 +-
.../testkit/query/EventsByTagSpec.scala | 30 +-
.../testkit/scaladsl/CommonSnapshotTests.scala | 34 +-
.../testkit/scaladsl/CommonTestKitTests.scala | 4 +-
...EventSourcedBehaviorNoSnapshotTestKitSpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorTestKitSpec.scala | 4 +-
.../testkit/scaladsl/MultipleJournalsSpec.scala | 4 +-
.../PersistenceProbeDurableStateSpec.scala | 264 ++
.../PersistenceProbeEventSourcedSpec.scala | 338 +++
.../PersistenceTestKitJournalCompatSpec.scala | 1 +
.../testkit/scaladsl/RuntimeJournalsSpec.scala | 4 +-
.../PersistenceTestKitDurableStateStoreSpec.scala | 27 +-
...ersistenceTestKitDurableStateStoreTCKSpec.scala | 32 +-
.../persistence/typed/MyReplicatedBehavior.java | 3 +-
.../typed/ReplicatedAuctionExampleTest.java | 39 +-
.../persistence/typed/ReplicatedMovieExample.java | 33 +-
.../typed/ReplicatedShoppingCartExample.java | 46 +-
.../typed/ReplicatedEventSourcingTest.java | 52 +-
.../javadsl/EventSourcedActorFailureTest.java | 24 +-
.../javadsl/EventSourcedBehaviorJavaDslTest.java | 75 +-
.../javadsl/RuntimeDurableStateStoreTest.java | 160 +
.../typed/ReplicatedAuctionExampleSpec.scala | 6 +-
.../ReplicatedEventSourcingCompileOnlySpec.scala | 4 +-
.../persistence/typed/EventPublishingSpec.scala | 1 +
.../typed/EventSourcedBehaviorLoggingSpec.scala | 7 +-
.../typed/MultiJournalReplicationSpec.scala | 8 +-
.../typed/ReplicatedEventPublishingSpec.scala | 111 +-
.../typed/ReplicatedEventSourcingSpec.scala | 1 +
.../typed/ReplicatedEventSourcingTaggingSpec.scala | 5 +-
.../persistence/typed/ReplicationBaseSpec.scala | 1 +
.../typed/ReplicationIllegalAccessSpec.scala | 1 +
.../typed/ReplicationSnapshotSpec.scala | 9 +-
.../pekko/persistence/typed/crdt/CounterSpec.scala | 2 +-
.../pekko/persistence/typed/crdt/LwwSpec.scala | 14 +-
.../pekko/persistence/typed/crdt/ORSetSpec.scala | 9 +-
.../ReplicatedEventSourcingJacksonSpec.scala | 4 +-
.../scaladsl/EventSourcedBehaviorFailureSpec.scala | 14 +-
.../EventSourcedBehaviorInterceptorSpec.scala | 10 +-
.../EventSourcedBehaviorRecoveryTimeoutSpec.scala | 18 +-
.../scaladsl/EventSourcedBehaviorReplySpec.scala | 15 +-
...urcedBehaviorRetentionOnlyOneSnapshotSpec.scala | 185 ++
.../EventSourcedBehaviorRetentionSpec.scala | 117 +-
.../scaladsl/EventSourcedBehaviorSignalSpec.scala | 14 +-
.../typed/scaladsl/EventSourcedBehaviorSpec.scala | 67 +-
.../scaladsl/EventSourcedBehaviorStashSpec.scala | 86 +-
.../scaladsl/EventSourcedBehaviorTimersSpec.scala | 10 +-
.../scaladsl/EventSourcedBehaviorWatchSpec.scala | 27 +-
.../scaladsl/EventSourcedEventAdapterSpec.scala | 8 +-
.../scaladsl/EventSourcedSequenceNumberSpec.scala | 6 +-
.../scaladsl/EventSourcedSnapshotAdapterSpec.scala | 8 +-
.../scaladsl/EventSourcedStashOverflowSpec.scala | 8 +-
.../typed/scaladsl/LoggerSourceSpec.scala | 8 +-
.../typed/scaladsl/NullEmptyStateSpec.scala | 4 +-
.../typed/scaladsl/OptionalSnapshotStoreSpec.scala | 5 +-
.../typed/scaladsl/PerformanceSpec.scala | 9 +-
.../typed/scaladsl/PrimitiveStateSpec.scala | 4 +-
.../typed/scaladsl/SlowInMemorySnapshotStore.scala | 8 +-
.../typed/scaladsl/SnapshotMutableStateSpec.scala | 10 +-
.../SnapshotRecoveryWithEmptyJournalSpec.scala | 13 +-
.../DurableStateBehaviorInterceptorSpec.scala | 12 +-
.../scaladsl/DurableStateBehaviorReplySpec.scala | 43 +-
...lySpec.scala => DurableStateBehaviorSpec.scala} | 123 +-
.../DurableStateBehaviorStashOverflowSpec.scala | 16 +-
.../scaladsl/DurableStateBehaviorTimersSpec.scala | 14 +-
.../state/scaladsl/DurableStateRevisionSpec.scala | 116 +-
.../typed/state/scaladsl/NullEmptyStateSpec.scala | 7 +-
.../typed/state/scaladsl/PrimitiveStateSpec.scala | 7 +-
.../scaladsl/RuntimeDurableStateStoreSpec.scala | 100 +
.../persistence/typed/javadsl/package-info.java | 15 +-
.../serialization/ReplicatedEventSourcing.java | 621 +++-
.../1.3.x.backwards.excludes/custom-stash.excludes | 5 +-
.../durablestate-runtime-config.excludes | 4 +-
.../external-replication.excludes | 7 +-
.../tags-for-state.excludes | 7 +-
.../main/protobuf/ReplicatedEventSourcing.proto | 1 +
.../pekko/persistence/typed/EventAdapter.scala | 2 +-
.../pekko/persistence/typed/crdt/ORSet.scala | 11 +-
.../typed/delivery/EventSourcedProducerQueue.scala | 28 +-
.../persistence/typed/internal/BehaviorSetup.scala | 143 +-
.../typed/internal/EventSourcedBehaviorImpl.scala | 43 +-
.../typed/internal/EventSourcedSettings.scala | 27 +-
.../typed/internal/ExternalInteractions.scala | 34 +-
.../typed/internal/ReplayingEvents.scala | 21 +-
.../typed/internal/ReplayingSnapshot.scala | 17 +-
.../typed/internal/ReplicationSetup.scala | 11 +-
.../typed/internal/RequestingRecoveryPermit.scala | 7 +-
.../typed/internal/RetentionCriteriaImpl.scala | 12 +-
.../pekko/persistence/typed/internal/Running.scala | 152 +-
.../persistence/typed/internal/VersionVector.scala | 1 +
.../persistence/typed/javadsl/CommandHandler.scala | 9 +-
.../typed/javadsl/CommandHandlerWithReply.scala | 13 +-
.../pekko/persistence/typed/javadsl/Effect.scala | 7 +-
.../persistence/typed/javadsl/EventHandler.scala | 7 +-
.../typed/javadsl/EventSourcedBehavior.scala | 67 +-
.../typed/javadsl/PersistentFSMMigration.scala | 9 +-
.../typed/javadsl/ReplicatedEventSourcing.scala | 9 +-
.../typed/javadsl/RetentionCriteria.scala | 14 +-
.../typed/scaladsl/EventSourcedBehavior.scala | 37 +-
.../typed/scaladsl/PersistentFSMMigration.scala | 2 +-
.../typed/scaladsl/ReplicatedEventSourcing.scala | 22 +
.../typed/scaladsl/RetentionCriteria.scala | 14 +-
.../ReplicatedEventSourcingSerializer.scala | 67 +-
.../typed/state/internal/BehaviorSetup.scala | 18 +-
.../state/internal/DurableStateBehaviorImpl.scala | 30 +-
.../state/internal/DurableStateSettings.scala | 57 +-
.../internal/DurableStateStoreInteractions.scala | 13 +-
.../typed/state/internal/Recovering.scala | 9 +-
.../state/internal/RequestingRecoveryPermit.scala | 5 +-
.../persistence/typed/state/internal/Running.scala | 53 +-
.../typed/state/javadsl/CommandHandler.scala | 11 +-
.../state/javadsl/CommandHandlerWithReply.scala | 15 +-
.../typed/state/javadsl/DurableStateBehavior.scala | 30 +-
.../persistence/typed/state/javadsl/Effect.scala | 4 +-
.../state/scaladsl/DurableStateBehavior.scala | 32 +-
.../persistence/typed/state/scaladsl/Effect.scala | 2 +-
.../typed/BasicPersistentBehaviorTest.java | 61 +-
.../pekko/persistence/typed/BlogPostEntity.java | 116 +-
.../typed/BlogPostEntityDurableState.java | 82 +-
.../typed/DurableStatePersistentBehaviorTest.java | 4 +
.../pekko/persistence/typed/MovieWatchList.java | 52 +-
.../pekko/persistence/typed/NullBlogState.java | 107 +-
.../pekko/persistence/typed/OptionalBlogState.java | 108 +-
...rsistentFsmToTypedMigrationCompileOnlyTest.java | 48 +-
.../persistence/typed/WebStoreCustomerFSM.java | 75 +-
.../persistence/typed/auction/AuctionCommand.java | 28 +-
.../persistence/typed/auction/AuctionEntity.java | 16 +-
.../persistence/typed/auction/AuctionState.java | 4 +-
.../pekko/persistence/typed/auction/Bid.java | 37 +-
.../typed/javadsl/LoggerSourceTest.java | 22 +-
.../typed/javadsl/NullEmptyStateTest.java | 22 +-
.../javadsl/PersistentActorCompileOnlyTest.java | 69 +-
.../typed/javadsl/PrimitiveStateTest.java | 22 +-
.../typed/BasicPersistentBehaviorCompileOnly.scala | 8 +-
...DurableStatePersistentBehaviorCompileOnly.scala | 24 +-
.../typed/ClusterSingletonPersistenceSpec.scala | 7 +-
.../persistence/typed/ManyRecoveriesSpec.scala | 7 +-
.../persistence/typed/PersistenceIdSpec.scala | 4 +-
.../ReplicatedEventSourcingSerializationSpec.scala | 1 +
.../typed/StashingWhenSnapshottingSpec.scala | 9 +-
.../delivery/EventSourcedProducerQueueSpec.scala | 11 +-
...DeliveryWithEventSourcedProducerQueueSpec.scala | 97 +-
...kPullingWithEventSourcedProducerQueueSpec.scala | 10 +-
.../typed/internal/RecoveryPermitterSpec.scala | 4 +-
.../typed/internal/RetentionCriteriaSpec.scala | 35 +-
.../typed/internal/StashStateSpec.scala | 6 +-
.../scaladsl/PersistentActorCompileOnlyTest.scala | 12 +-
.../typed/scaladsl/SnapshotIsOptionalSpec.scala | 10 +-
.../ReplicatedEventSourcingSerializerSpec.scala | 17 +-
.../fsm/japi/pf/FSMStateFunctionBuilder.java | 6 +-
.../persistence/fsm/japi/pf/FSMStopBuilder.java | 6 +-
.../journal/japi/AsyncRecoveryPlugin.java | 4 +-
.../persistence/journal/japi/package-info.java | 15 +-
.../persistence/serialization/MessageFormats.java | 219 +-
.../persistence/snapshot/japi/package-info.java | 15 +-
.../persistence/state/javadsl/package-info.java | 15 +-
.../fsm-transition-listeners.excludes | 4 +-
.../remove-deprecated-methods.excludes | 15 +
persistence/src/main/resources/reference.conf | 33 +-
.../org/apache/pekko/persistence/TraitOrder.scala | 2 +-
.../org/apache/pekko/persistence/TraitOrder.scala | 2 +-
.../pekko/persistence/AtLeastOnceDelivery.scala | 15 +-
.../apache/pekko/persistence/Eventsourced.scala | 12 +-
.../apache/pekko/persistence/FilteredPayload.scala | 26 +
.../apache/pekko/persistence/JournalProtocol.scala | 22 +-
.../org/apache/pekko/persistence/Persistence.scala | 20 +-
.../pekko/persistence/PersistencePlugin.scala | 14 +-
.../org/apache/pekko/persistence/Persistent.scala | 2 +-
.../apache/pekko/persistence/PersistentActor.scala | 6 +-
.../org/apache/pekko/persistence/Snapshotter.scala | 8 +-
.../pekko/persistence/fsm/PersistentFSM.scala | 19 +-
.../pekko/persistence/fsm/PersistentFSMBase.scala | 97 +-
.../pekko/persistence/journal/EventAdapters.scala | 31 +-
.../journal/PersistencePluginProxy.scala | 8 +-
.../apache/pekko/persistence/journal/Tagged.scala | 3 +-
.../persistence/journal/inmem/InmemJournal.scala | 22 +-
.../persistence/journal/japi/AsyncRecovery.scala | 8 +-
.../journal/japi/AsyncWriteJournal.scala | 12 +-
.../journal/leveldb/LeveldbCompaction.scala | 2 +-
.../journal/leveldb/LeveldbIdMapping.scala | 5 +-
.../journal/leveldb/LeveldbJournal.scala | 8 +-
.../persistence/journal/leveldb/LeveldbStore.scala | 5 +-
.../journal/leveldb/SharedLeveldbStore.scala | 4 +-
.../serialization/FilteredPayloadSerializer.scala | 45 +
.../serialization/MessageSerializer.scala | 12 +-
.../serialization/SnapshotSerializer.scala | 65 +-
.../pekko/persistence/serialization/package.scala | 19 +-
.../persistence/snapshot/japi/SnapshotStore.scala | 17 +-
.../snapshot/local/LocalSnapshotStore.scala | 12 +-
.../state/DurableStateStoreProvider.scala | 6 +-
.../state/DurableStateStoreRegistry.scala | 55 +-
.../state/javadsl/DurableStateStore.scala | 3 +-
.../state/javadsl/DurableStateUpdateStore.scala | 8 +-
.../state/scaladsl/DurableStateStore.scala | 2 +-
.../state/scaladsl/DurableStateUpdateStore.scala | 8 +-
.../persistence/fsm/AbstractPersistentFSMTest.java | 84 +-
.../AtLeastOnceDeliveryFailureSpec.scala | 4 +-
.../persistence/AtLeastOnceDeliverySpec.scala | 11 +-
.../persistence/EndToEndEventAdapterSpec.scala | 27 +-
.../pekko/persistence/EventAdapterSpec.scala | 4 +-
.../apache/pekko/persistence/LoadPluginSpec.scala | 8 +-
.../pekko/persistence/ManyRecoveriesSpec.scala | 4 +-
.../persistence/OptionalSnapshotStoreSpec.scala | 4 +-
.../apache/pekko/persistence/PerformanceSpec.scala | 4 +-
.../apache/pekko/persistence/PersistenceSpec.scala | 8 +-
.../PersistentActorBoundedStashingSpec.scala | 7 +-
.../PersistentActorJournalProtocolSpec.scala | 4 +-
.../PersistentActorRecoveryTimeoutSpec.scala | 41 +-
.../pekko/persistence/PersistentActorSpec.scala | 8 +-
.../persistence/PersistentActorStashingSpec.scala | 8 +-
.../pekko/persistence/RecoveryPermitterSpec.scala | 4 +-
.../SnapshotFailureRobustnessSpec.scala | 4 +-
.../SnapshotRecoveryWithEmptyJournalSpec.scala | 2 +-
.../persistence/SnapshotSerializationSpec.scala | 2 +-
.../apache/pekko/persistence/SnapshotSpec.scala | 2 +-
.../persistence/TimerPersistentActorSpec.scala | 4 +-
.../pekko/persistence/fsm/PersistentFSMSpec.scala | 35 +-
.../AsyncWriteJournalResponseOrderSpec.scala | 104 +-
.../journal/InmemEventAdaptersSpec.scala | 7 +-
.../persistence/journal/SteppingInmemJournal.scala | 16 +-
.../journal/leveldb/JournalCompactionSpec.scala | 3 +-
.../FilteredPayloadSerializerSpec.scala | 35 +
.../serialization/MessageSerializerSpec.scala | 4 +-
.../SnapshotSerializerMigrationAkkaSpec.scala | 15 +-
.../SnapshotSerializerNoMigrationSpec.scala | 10 +-
.../serialization/SnapshotSerializerSpec.scala | 61 +-
.../exception/DurableStateExceptionsSpec.scala | 4 +-
.../apache/pekko/pki/pem/DERPrivateKeyLoader.scala | 7 +-
.../src/main/resources/plugin.properties | 1 -
.../src/main/scala/org/apache/pekko/Plugin.scala | 51 -
project/AddLogTimestamps.scala | 2 +-
project/CopyrightHeader.scala | 14 +-
project/CopyrightHeaderForBoilerplate.scala | 4 +-
project/CopyrightHeaderForBuild.scala | 4 +-
...ForJdk9.scala => CopyrightHeaderForJdk21.scala} | 10 +-
project/CopyrightHeaderForProtobuf.scala | 4 +-
project/Dependencies.scala | 172 +-
project/Doc.scala | 5 +-
project/JavaFormatter.scala | 2 +-
project/{Jdk9.scala => Jdk21.scala} | 41 +-
project/JdkOptions.scala | 18 +-
project/MultiNode.scala | 6 +-
project/OSGi.scala | 38 +-
project/Paradox.scala | 16 +-
project/PekkoBuild.scala | 52 +-
project/PekkoDevelocityPlugin.scala | 10 +-
project/PekkoDisciplinePlugin.scala | 55 +-
project/ProjectFileIgnoreSupport.scala | 8 +-
project/ProjectIndexGenerator.scala | 74 -
project/Protobuf.scala | 2 +-
project/SbtMultiJvmPlugin.scala | 7 +-
project/ScalaFixExtraRulesPlugin.scala | 7 +-
...k9Plugin.scala => ScalaFixForJdk21Plugin.scala} | 12 +-
project/ScalafixForMultiNodePlugin.scala | 4 +-
project/ScalafixIgnoreFilePlugin.scala | 4 +-
project/StreamOperatorsIndexGenerator.scala | 6 +-
project/TestExtras.scala | 13 +-
project/ValidatePullRequest.scala | 2 +-
project/VerifyJDK9Classes.scala | 85 -
project/VersionGenerator.scala | 2 +-
project/build.properties | 2 +-
project/plugins.sbt | 36 +-
project/project-info.conf | 2 +-
.../pekko/remote/AttemptSysMsgRedeliverySpec.scala | 3 +-
.../pekko/remote/LookupRemoteActorSpec.scala | 3 +-
.../apache/pekko/remote/NewRemoteActorSpec.scala | 7 +-
.../remote/PiercingShouldKeepQuarantineSpec.scala | 4 +-
.../apache/pekko/remote/RemoteDeliverySpec.scala | 4 +-
.../remote/RemoteDeploymentDeathWatchSpec.scala | 4 +-
.../apache/pekko/remote/RemoteFeaturesSpec.scala | 4 +-
.../pekko/remote/RemoteNodeDeathWatchSpec.scala | 4 +-
.../remote/RemoteNodeRestartDeathWatchSpec.scala | 4 +-
.../remote/RemoteQuarantinePiercingSpec.scala | 4 +-
.../pekko/remote/RemoteReDeploymentSpec.scala | 4 +-
.../pekko/remote/RemotingMultiNodeSpec.scala | 7 +-
.../apache/pekko/remote/TransportFailSpec.scala | 12 +-
.../pekko/remote/artery/DirectMemorySpec.scala | 4 +-
.../pekko/remote/artery/FanInThrougputSpec.scala | 4 +-
.../pekko/remote/artery/FanOutThrougputSpec.scala | 4 +-
.../artery/HandshakeRestartReceiverSpec.scala | 4 +-
.../apache/pekko/remote/artery/LatencySpec.scala | 3 +-
.../pekko/remote/artery/MaxThroughputSpec.scala | 3 +-
.../artery/RemoteRestartedQuarantinedSpec.scala | 4 +-
...dStreamRestartWithCompressionInFlightSpec.scala | 7 +-
.../artery/SurviveNetworkPartitionSpec.scala | 6 +-
.../apache/pekko/remote/artery/TestMessage.scala | 6 +-
.../artery/aeron/AeronStreamConcistencySpec.scala | 3 +-
.../artery/aeron/AeronStreamLatencySpec.scala | 3 +-
.../aeron/AeronStreamMaxThroughputSpec.scala | 7 +-
.../remote/classic/RemoteGatePiercingSpec.scala | 6 +-
.../remote/classic/RemoteNodeRestartGateSpec.scala | 6 +-
.../RemoteNodeShutdownAndComesBackSpec.scala | 4 +-
.../pekko/remote/classic/Ticket15109Spec.scala | 6 +-
.../pekko/remote/routing/RemoteRandomSpec.scala | 7 +-
.../remote/routing/RemoteRoundRobinSpec.scala | 4 +-
.../remote/routing/RemoteScatterGatherSpec.scala | 7 +-
.../remote/testconductor/TestConductorSpec.scala | 4 +-
.../pekko/remote/artery/protobuf/TestMessages.java | 81 +-
.../remote/artery/ArteryFailedToBindSpec.scala | 11 +-
.../remote/classic/RemotingFailedToBindSpec.scala | 10 +-
.../pekko/remote/testconductor/BarrierSpec.scala | 2 +-
.../remote/testconductor/ControllerSpec.scala | 2 +-
.../apache/pekko/remote/ArteryControlFormats.java | 317 +-
.../org/apache/pekko/remote/ContainerFormats.java | 397 ++-
.../apache/pekko/remote/SystemMessageFormats.java | 163 +-
.../java/org/apache/pekko/remote/WireFormats.java | 603 ++--
.../pekko/remote/artery/aeron/AeronErrorLog.java | 12 +-
.../remote/artery/compress/CountMinSketch.java | 12 +-
.../future-lazy-vals.excludes | 6 +-
.../remove-deprecated-methods.excludes | 4 +
remote/src/main/resources/reference.conf | 30 +-
.../org/apache/pekko/remote/AckedDelivery.scala | 26 +-
.../apache/pekko/remote/AddressUidExtension.scala | 2 +-
.../org/apache/pekko/remote/ByteStringUtils.scala | 2 +-
.../pekko/remote/DeadlineFailureDetector.scala | 4 +-
.../scala/org/apache/pekko/remote/Endpoint.scala | 133 +-
.../pekko/remote/FailureDetectorRegistry.scala | 8 +-
.../apache/pekko/remote/MessageSerializer.scala | 7 +-
.../pekko/remote/PhiAccrualFailureDetector.scala | 7 +-
.../pekko/remote/RemoteActorRefProvider.scala | 7 +-
.../org/apache/pekko/remote/RemoteDaemon.scala | 4 +-
.../org/apache/pekko/remote/RemoteDeployer.scala | 5 +-
.../pekko/remote/RemoteMetricsExtension.scala | 5 +-
.../org/apache/pekko/remote/RemoteSettings.scala | 16 +-
.../org/apache/pekko/remote/RemoteTransport.scala | 7 +-
.../org/apache/pekko/remote/RemoteWatcher.scala | 6 +-
.../scala/org/apache/pekko/remote/Remoting.scala | 100 +-
.../pekko/remote/RemotingLifecycleEvent.scala | 6 +-
.../pekko/remote/artery/ArterySettings.scala | 18 +-
.../pekko/remote/artery/ArteryTransport.scala | 126 +-
.../apache/pekko/remote/artery/Association.scala | 55 +-
.../org/apache/pekko/remote/artery/Codecs.scala | 12 +-
.../org/apache/pekko/remote/artery/Control.scala | 7 +-
.../pekko/remote/artery/EnvelopeBufferPool.scala | 18 +-
.../artery/FlushBeforeDeathWatchNotification.scala | 2 +-
.../pekko/remote/artery/FlushOnShutdown.scala | 3 +-
.../org/apache/pekko/remote/artery/Handshake.scala | 10 +-
.../pekko/remote/artery/ImmutableLongMap.scala | 5 +-
.../pekko/remote/artery/LruBoundedCache.scala | 14 +-
.../pekko/remote/artery/MessageDispatcher.scala | 3 +-
.../pekko/remote/artery/RemoteInstrument.scala | 16 +-
.../remote/artery/RemotingFlightRecorder.scala | 5 +-
.../remote/artery/SystemMessageDelivery.scala | 18 +-
.../org/apache/pekko/remote/artery/TestStage.scala | 2 +
.../pekko/remote/artery/aeron/AeronSink.scala | 5 +-
.../pekko/remote/artery/aeron/AeronSource.scala | 12 +-
.../artery/aeron/ArteryAeronUdpTransport.scala | 27 +-
.../pekko/remote/artery/aeron/TaskRunner.scala | 8 +-
.../remote/artery/compress/CompressionTable.scala | 9 +-
.../artery/compress/DecompressionTable.scala | 4 +-
.../artery/compress/InboundCompressions.scala | 90 +-
.../remote/artery/compress/TopHeavyHitters.scala | 110 +-
.../remote/artery/tcp/ArteryTcpTransport.scala | 16 +-
.../artery/tcp/ConfigSSLEngineProvider.scala | 21 +-
.../remote/artery/tcp/SSLEngineProvider.scala | 7 +-
.../remote/artery/tcp/SecureRandomFactory.scala | 1 +
.../pekko/remote/artery/tcp/TcpFraming.scala | 2 +-
.../artery/tcp/ssl/PemManagersProvider.scala | 10 +-
.../tcp/ssl/RotatingKeysSSLEngineProvider.scala | 15 +-
.../remote/artery/tcp/ssl/SSLEngineConfig.scala | 9 +-
.../remote/artery/tcp/ssl/SessionVerifier.scala | 2 +-
.../pekko/remote/artery/tcp/ssl/X509Readers.scala | 7 +-
.../pekko/remote/routing/RemoteRouterConfig.scala | 7 +-
.../serialization/ActorRefResolveCache.scala | 4 +-
.../serialization/ArteryMessageSerializer.scala | 6 +-
.../serialization/DaemonMsgCreateSerializer.scala | 12 +-
.../serialization/MessageContainerSerializer.scala | 7 +-
.../serialization/MiscMessageSerializer.scala | 20 +-
.../remote/serialization/ProtobufSerializer.scala | 22 +-
.../serialization/SystemMessageSerializer.scala | 2 +-
.../remote/serialization/ThrowableSupport.scala | 2 +-
.../serialization/WrappedPayloadSupport.scala | 6 +-
.../transport/AbstractTransportAdapter.scala | 3 +-
.../FailureInjectorTransportAdapter.scala | 2 +-
.../pekko/remote/transport/PekkoPduCodec.scala | 7 +-
.../remote/transport/PekkoProtocolTransport.scala | 8 +-
.../pekko/remote/transport/TestTransport.scala | 4 +-
.../transport/ThrottlerTransportAdapter.scala | 72 +-
.../apache/pekko/remote/transport/Transport.scala | 21 +-
.../remote/transport/netty/NettyHelpers.scala | 13 +-
.../remote/transport/netty/NettySSLSupport.scala | 43 +-
.../remote/transport/netty/NettyTransport.scala | 24 +-
.../remote/transport/netty/SSLEngineProvider.scala | 46 +-
.../org/apache/pekko/remote/ProtobufProtocol.java | 39 +-
.../pekko/remote/artery/aeron/AeronStat.java | 87 -
.../remote/protobuf/v3/ProtobufProtocolV3.java | 40 +-
.../transport/ThrottlerTransportAdapterTest.java | 1 +
remote/src/test/protobuf/ProtobufProtocolV3.proto | 2 +-
.../pekko/remote/AccrualFailureDetectorSpec.scala | 10 +-
.../apache/pekko/remote/AckedDeliverySpec.scala | 14 +-
.../pekko/remote/ConfigSSLEngineProviderSpec.scala | 47 +
.../org/apache/pekko/remote/DaemonicSpec.scala | 15 +-
.../pekko/remote/DeadlineFailureDetectorSpec.scala | 3 +-
.../apache/pekko/remote/MessageLoggingSpec.scala | 5 +-
.../apache/pekko/remote/NetworkFailureSpec.scala | 2 +-
.../remote/ReliableDeliverySupervisorSpec.scala | 225 ++
.../pekko/remote/RemoteActorMailboxSpec.scala | 4 +-
.../org/apache/pekko/remote/RemoteConfigSpec.scala | 6 +-
.../apache/pekko/remote/RemoteDeployerSpec.scala | 4 +-
.../apache/pekko/remote/RemoteFeaturesSpec.scala | 8 +-
.../org/apache/pekko/remote/RemoteRouterSpec.scala | 4 +-
.../pekko/remote/Ticket1978CommunicationSpec.scala | 8 +-
.../apache/pekko/remote/Ticket1978ConfigSpec.scala | 10 +
.../remote/TransientSerializationErrorSpec.scala | 14 +-
.../ActorRefResolveCacheQuarantineSpec.scala | 4 +-
.../ActorSelectionQueueDistributionSpec.scala | 288 ++
.../pekko/remote/artery/ArteryMultiNodeSpec.scala | 7 +-
.../remote/artery/BindCanonicalAddressSpec.scala | 11 +-
.../pekko/remote/artery/DuplicateFlushSpec.scala | 7 +-
.../remote/artery/DuplicateHandshakeSpec.scala | 7 +-
.../pekko/remote/artery/EnvelopeBufferSpec.scala | 1 +
.../pekko/remote/artery/HandshakeDenySpec.scala | 4 +-
.../pekko/remote/artery/HandshakeFailureSpec.scala | 4 +-
.../pekko/remote/artery/HandshakeRetrySpec.scala | 9 +-
.../remote/artery/HarmlessQuarantineSpec.scala | 8 +-
.../pekko/remote/artery/ImmutableLongMapSpec.scala | 13 +-
.../remote/artery/InboundControlJunctionSpec.scala | 7 +-
.../pekko/remote/artery/InboundHandshakeSpec.scala | 7 +-
.../pekko/remote/artery/LateConnectSpec.scala | 18 +-
.../pekko/remote/artery/LruBoundedCacheSpec.scala | 3 +-
.../pekko/remote/artery/MetadataCarryingSpec.scala | 2 +-
.../artery/OutboundControlJunctionSpec.scala | 7 +-
.../remote/artery/OutboundHandshakeSpec.scala | 7 +-
.../remote/artery/OutboundIdleShutdownSpec.scala | 13 +-
.../pekko/remote/artery/RemoteDeathWatchSpec.scala | 6 +-
.../pekko/remote/artery/RemoteDeployerSpec.scala | 4 +-
.../pekko/remote/artery/RemoteDeploymentSpec.scala | 4 +-
.../pekko/remote/artery/RemoteFailureSpec.scala | 10 +-
.../RemoteInstrumentsSerializationSpec.scala | 18 +-
.../remote/artery/RemoteInstrumentsSpec.scala | 3 +-
.../artery/RemoteMessageSerializationSpec.scala | 3 +-
.../pekko/remote/artery/RemoteRouterSpec.scala | 4 +-
.../remote/artery/RemoteSendConsistencySpec.scala | 8 +-
.../pekko/remote/artery/RemoteWatcherSpec.scala | 7 +-
.../remote/artery/RemotingFlightRecorderSpec.scala | 10 +-
.../apache/pekko/remote/artery/SendQueueSpec.scala | 23 +-
.../remote/artery/SystemMessageAckerSpec.scala | 7 +-
.../remote/artery/SystemMessageDeliverySpec.scala | 58 +-
.../apache/pekko/remote/artery/TestContext.scala | 8 +-
.../apache/pekko/remote/artery/UntrustedSpec.scala | 4 +-
.../pekko/remote/artery/aeron/AeronSinkSpec.scala | 2 +-
.../compress/CompressionIntegrationSpec.scala | 54 +-
.../HandshakeShouldDropCompressionTableSpec.scala | 7 +-
.../remote/artery/compress/HeavyHittersSpec.scala | 34 +
.../artery/jfr/JFRRemotingFlightRecorderSpec.scala | 4 +-
.../tcp/ArteryConfigSSLEngineProviderSpec.scala | 43 +
.../artery/tcp/SecureRandomFactorySpec.scala | 2 +-
.../pekko/remote/artery/tcp/TcpFramingSpec.scala | 6 +-
.../pekko/remote/artery/tcp/TlsTcpSpec.scala | 14 +-
.../artery/tcp/ssl/CipherSuiteSupportCheck.scala | 7 +-
.../artery/tcp/ssl/PeerSubjectVerifierSpec.scala | 2 +-
.../artery/tcp/ssl/PemManagersProviderSpec.scala | 1 +
.../ssl/RotatingKeysSSLEngineProviderSpec.scala | 100 +-
.../remote/artery/tcp/ssl/TlsResourcesSpec.scala | 7 +-
.../pekko/remote/classic/ActorsLeakSpec.scala | 6 +-
.../remote/classic/RemoteDeathWatchSpec.scala | 6 +-
.../classic/RemoteDeploymentAllowListSpec.scala | 6 +-
.../pekko/remote/classic/RemoteInitErrorSpec.scala | 9 +-
.../pekko/remote/classic/RemoteSettingsSpec.scala | 8 +-
.../pekko/remote/classic/RemoteWatcherSpec.scala | 6 +-
.../apache/pekko/remote/classic/RemotingSpec.scala | 127 +-
.../pekko/remote/classic/UntrustedSpec.scala | 6 +-
.../classic/transport/GenericTransportSpec.scala | 3 +-
.../classic/transport/PekkoProtocolSpec.scala | 8 +-
.../transport/PekkoProtocolStressTest.scala | 4 +-
.../SystemMessageDeliveryStressTest.scala | 6 +-
.../classic/transport/TestTransportSpec.scala | 3 +-
.../transport/ThrottlerTransportAdapterSpec.scala | 6 +-
.../AllowJavaSerializationOffSpec.scala | 4 +-
.../ArteryMessageSerializerSpec.scala | 4 +-
...reateSerializerAllowJavaSerializationSpec.scala | 18 +-
.../serialization/MiscMessageSerializerSpec.scala | 17 +-
.../serialization/ProtobufSerializerSpec.scala | 11 +-
.../SerializationTransportInformationSpec.scala | 9 +-
.../SystemMessageSerializationSpec.scala | 6 +-
.../remote/transport/NettyTransportSpec.scala | 14 +-
.../remote/transport/ThrottlerHandleSpec.scala | 130 +
.../transport/netty/NettySSLSupportSpec.scala | 43 +
scripts/find-javadoc-error.pl | 15 -
scripts/link-validator.conf | 10 +-
.../jackson/FiniteDurationModule.scala | 6 +-
.../serialization/jackson/JacksonMigration.scala | 6 +-
.../serialization/jackson/JacksonModule.scala | 14 +-
.../jackson/JacksonObjectMapperProvider.scala | 63 +-
.../serialization/jackson/JacksonSerializer.scala | 44 +-
.../jackson/PekkoSerializationModule.scala | 1 +
.../serialization/jackson/StreamRefModule.scala | 24 +-
.../jackson/TypedActorRefModule.scala | 12 +-
.../serialization/jackson/JacksonFactorySpec.scala | 11 +-
.../jackson/JacksonSerializerSpec.scala | 30 +-
.../src/main/resources/reference.conf | 271 ++
.../serialization/jackson3/ActorRefModule.scala | 77 +
.../serialization/jackson3/ActorSystemAccess.scala | 38 +
.../serialization/jackson3/AddressModule.scala | 71 +
.../jackson3}/FiniteDurationModule.scala | 30 +-
.../serialization/jackson3}/JacksonMigration.scala | 8 +-
.../serialization/jackson3}/JacksonModule.scala | 56 +-
.../jackson3}/JacksonObjectMapperProvider.scala | 522 ++--
.../jackson3}/JacksonSerializer.scala | 59 +-
.../jackson3/PekkoJacksonModule.scala | 35 +
.../jackson3}/PekkoSerializationModule.scala | 29 +-
.../serialization/jackson3}/StreamRefModule.scala | 46 +-
.../jackson3}/TypedActorRefModule.scala | 30 +-
.../serialization/jackson3/MySerializable.java | 29 +
.../jackson3/SerializationDocTest.java | 99 +
.../pekko/serialization/jackson3/v1/Customer.java | 34 +
.../pekko/serialization/jackson3/v1/ItemAdded.java | 32 +
.../serialization/jackson3/v1/OrderAdded.java | 28 +
.../jackson3/v1withv2/ItemAddedMigration.java | 46 +
.../pekko/serialization/jackson3/v2a/Address.java | 30 +
.../pekko/serialization/jackson3/v2a/Customer.java | 31 +
.../jackson3/v2a/CustomerMigration.java | 45 +
.../serialization/jackson3/v2a/ItemAdded.java | 50 +
.../serialization/jackson3/v2a/OrderPlaced.java | 28 +
.../jackson3/v2a/OrderPlacedMigration.java | 37 +
.../serialization/jackson3/v2b/ItemAdded.java | 32 +
.../jackson3/v2b/ItemAddedMigration.java | 38 +
.../serialization/jackson3/v2c/ItemAdded.java | 32 +
.../jackson3/v2c/ItemAddedMigration.java | 39 +
.../jackson3/JavaTestEventMigrationV2.java | 41 +
.../jackson3/JavaTestEventMigrationV2WithV3.java | 65 +
.../jackson3/JavaTestEventMigrationV3.java | 58 +
.../serialization/jackson3/JavaTestMessages.java | 552 ++++
.../src/test/resources/reference.conf | 10 +
.../jackson3/CustomAdtSerializer.scala | 68 +
.../jackson3/SerializationDocSpec.scala | 411 +++
.../pekko/serialization/jackson3/v1/Customer.scala | 15 +-
.../serialization/jackson3/v1/ItemAdded.scala | 17 +-
.../serialization/jackson3/v1/OrderAdded.scala | 15 +-
.../jackson3/v1withv2/ItemAddedMigration.scala | 38 +
.../pekko/serialization/jackson3/v2a/Address.scala | 15 +-
.../serialization/jackson3/v2a/Customer.scala | 15 +-
.../jackson3/v2a/CustomerMigration.scala | 41 +
.../serialization/jackson3/v2a/ItemAdded.scala | 28 +
.../serialization/jackson3/v2a/OrderPlaced.scala | 15 +-
.../jackson3/v2a/OrderPlacedMigration.scala | 29 +
.../serialization/jackson3/v2b/ItemAdded.scala | 15 +-
.../jackson3/v2b/ItemAddedMigration.scala | 34 +
.../serialization/jackson3/v2c/ItemAdded.scala | 15 +-
.../jackson3/v2c/ItemAddedMigration.scala | 34 +
.../serialization/jackson3/CborSerializable.scala | 13 +-
.../jackson3}/JacksonFactorySpec.scala | 58 +-
.../jackson3}/JacksonSerializerSpec.scala | 317 +-
.../serialization/jackson3/JsonSerializable.scala | 13 +-
.../jackson3/ScalaTestEventMigration.scala | 103 +
.../org/apache/pekko/event/slf4j/Slf4jLogger.scala | 26 +-
.../apache/pekko/event/slf4j/Slf4jLoggerSpec.scala | 10 +-
.../pekko/event/slf4j/Slf4jLoggingFilterSpec.scala | 4 +-
.../pekko/stream/testkit/javadsl/package-info.java | 15 +-
.../fix-java-unchecked-warnings.excludes | 46 +
.../remove-deprecated-methods.excludes | 4 +
.../pekko/stream/testkit/StreamTestKit.scala | 194 +-
.../stream/testkit/javadsl/StreamTestKit.scala | 9 +-
.../pekko/stream/testkit/javadsl/TestSink.scala | 9 +-
.../pekko/stream/testkit/javadsl/TestSource.scala | 9 +-
.../pekko/stream/testkit/scaladsl/TestSink.scala | 12 +-
.../pekko/stream/testkit/scaladsl/TestSource.scala | 12 +-
.../impl/fusing/GraphInterpreterSpecKit.scala | 41 +-
.../apache/pekko/stream/testkit/ChainSetup.scala | 6 +-
.../apache/pekko/stream/testkit/ScriptedTest.scala | 2 +-
.../pekko/stream/testkit/StreamConfiguration.scala | 5 +-
.../apache/pekko/stream/testkit/StreamSpec.scala | 48 +-
.../pekko/stream/testkit/StreamTestKitSpec.scala | 42 +-
.../pekko/stream/testkit/TwoStreamsSetup.scala | 2 +-
.../pekko/stream/tck/ActorSystemLifecycle.scala | 21 +-
.../stream/tck/CancelledSinkSubscriberTest.scala | 3 +-
.../org/apache/pekko/stream/tck/ConcatTest.scala | 4 +-
.../pekko/stream/tck/EmptyPublisherTest.scala | 4 +-
.../pekko/stream/tck/FanoutPublisherTest.scala | 4 +-
.../pekko/stream/tck/FilePublisherTest.scala | 3 +-
.../tck/FlatMapConcatDoubleSubscriberTest.scala | 6 +-
.../pekko/stream/tck/FlatMapPrefixTest.scala | 4 +-
.../org/apache/pekko/stream/tck/FlattenTest.scala | 4 +-
.../pekko/stream/tck/FoldSinkSubscriberTest.scala | 4 +-
.../stream/tck/ForeachSinkSubscriberTest.scala | 4 +-
.../pekko/stream/tck/FusableProcessorTest.scala | 4 +-
.../pekko/stream/tck/FuturePublisherTest.scala | 4 +-
.../org/apache/pekko/stream/tck/GroupByTest.scala | 6 +-
.../pekko/stream/tck/InputStreamSourceTest.scala | 25 +-
.../pekko/stream/tck/IterablePublisherTest.scala | 4 +-
...IterablePublisherViaJavaFlowPublisherTest.scala | 3 +-
.../org/apache/pekko/stream/tck/MapTest.scala | 4 +-
.../apache/pekko/stream/tck/MaybeSourceTest.scala | 4 +-
.../tck/PekkoIdentityProcessorVerification.scala | 9 +-
.../stream/tck/PekkoPublisherVerification.scala | 10 +-
.../stream/tck/PekkoSubscriberVerification.scala | 7 +-
.../pekko/stream/tck/PrefixAndTailTest.scala | 6 +-
.../pekko/stream/tck/SingleElementSourceTest.scala | 4 +-
.../pekko/stream/tck/SinkholeSubscriberTest.scala | 7 +-
.../apache/pekko/stream/tck/SplitWhenTest.scala | 4 +-
.../org/apache/pekko/stream/tck/Timeouts.scala | 20 +-
.../pekko/stream/tck/TransformProcessorTest.scala | 4 +-
.../pekko/stream/tck/VirtualPublisherTest.scala | 4 +-
.../pekko/stream/StreamAttributeDocTest.java | 14 +-
.../java/org/apache/pekko/stream/StreamTest.java | 8 +-
.../org/apache/pekko/stream/StreamTestJupiter.java | 62 +
.../pekko/stream/io/InputStreamSinkTest.java | 21 +-
.../pekko/stream/io/OutputStreamSinkTest.java | 33 +-
.../pekko/stream/io/OutputStreamSourceTest.java | 19 +-
.../pekko/stream/io/SinkAsJavaSourceTest.java | 25 +-
.../pekko/stream/javadsl/AttributesTest.java | 25 +-
.../org/apache/pekko/stream/javadsl/FlowTest.java | 426 ++-
.../pekko/stream/javadsl/FlowThrottleTest.java | 25 +-
.../pekko/stream/javadsl/FlowUnfoldAsyncTest.java | 20 +-
.../pekko/stream/javadsl/FlowWithContextTest.java | 152 +-
.../javadsl/FlowWithContextThrottleTest.java | 18 +-
.../apache/pekko/stream/javadsl/FramingTest.java | 16 +-
.../apache/pekko/stream/javadsl/GraphDslTest.java | 80 +-
.../stream/javadsl/JavaFlowSupportCompileTest.java | 5 +-
.../pekko/stream/javadsl/JsonFramingTest.java | 18 +-
.../pekko/stream/javadsl/KillSwitchTest.java | 16 +-
.../stream/javadsl/LazyAndFutureFlowTest.java | 25 +-
.../stream/javadsl/LazyAndFutureSourcesTest.java | 40 +-
.../apache/pekko/stream/javadsl/RetryFlowTest.java | 34 +-
.../pekko/stream/javadsl/RunnableGraphTest.java | 18 +-
.../org/apache/pekko/stream/javadsl/SetupTest.java | 18 +-
.../org/apache/pekko/stream/javadsl/SinkTest.java | 62 +-
.../apache/pekko/stream/javadsl/SourceTest.java | 523 ++--
.../stream/javadsl/SourceWithContextTest.java | 158 +
.../javadsl/SourceWithContextThrottleTest.java | 22 +-
.../org/apache/pekko/stream/javadsl/TcpTest.java | 46 +-
.../org/apache/pekko/stream/stage/StageTest.java | 24 +-
stream-tests/src/test/resources/application.conf | 11 +
.../apache/pekko/stream/DslConsistencySpec.scala | 47 +-
.../pekko/stream/DslFactoriesConsistencySpec.scala | 64 +-
.../scala/org/apache/pekko/stream/FusingSpec.scala | 210 +-
.../pekko/stream/impl/FanoutProcessorSpec.scala | 113 -
.../stream/impl/FanoutPublisherBehaviorSpec.scala | 253 ++
.../apache/pekko/stream/impl/FixedBufferSpec.scala | 16 +-
.../pekko/stream/impl/GraphStageLogicSpec.scala | 10 +-
.../stream/impl/LinearTraversalBuilderSpec.scala | 3 +-
.../pekko/stream/impl/SubInletOutletSpec.scala | 8 +-
.../apache/pekko/stream/impl/TimeoutsSpec.scala | 93 +
.../pekko/stream/impl/TraversalBuilderSpec.scala | 65 +-
.../impl/fusing/ActorGraphInterpreterSpec.scala | 116 +-
.../stream/impl/fusing/AsyncCallbackSpec.scala | 8 +-
.../pekko/stream/impl/fusing/InterpreterSpec.scala | 3 +-
.../impl/fusing/LifecycleInterpreterSpec.scala | 6 +-
.../pekko/stream/io/ByteStringParserSpec.scala | 3 +-
.../org/apache/pekko/stream/io/FileSinkSpec.scala | 7 +-
.../apache/pekko/stream/io/FileSourceSpec.scala | 82 +-
.../pekko/stream/io/InputStreamSinkSpec.scala | 14 +-
.../pekko/stream/io/InputStreamSourceSpec.scala | 2 +-
.../pekko/stream/io/OutputStreamSourceSpec.scala | 16 +-
.../scala/org/apache/pekko/stream/io/TcpSpec.scala | 27 +-
.../stream/io/TlsGraphStageEdgeCasesSpec.scala | 340 +++
.../stream/io/TlsGraphStageIsolatedSpec.scala | 238 ++
.../scala/org/apache/pekko/stream/io/TlsSpec.scala | 96 +-
.../pekko/stream/io/compression/CoderSpec.scala | 7 +-
.../io/compression/CompressionTestingTools.scala | 2 -
.../io/compression/DeflateAutoFlushSpec.scala | 24 +-
.../stream/io/compression/GzipAutoFlushSpec.scala | 24 +-
.../pekko/stream/io/compression/GzipSpec.scala | 2 +-
.../scaladsl/ActorRefBackpressureSinkSpec.scala | 15 +-
.../scaladsl/ActorRefBackpressureSourceSpec.scala | 10 +-
.../pekko/stream/scaladsl/ActorRefSinkSpec.scala | 5 +-
.../pekko/stream/scaladsl/ActorRefSourceSpec.scala | 93 +-
.../scaladsl/AggregateWithBoundarySpec.scala | 128 +-
.../pekko/stream/scaladsl/AttributesSpec.scala | 5 +-
.../stream/scaladsl/BoundedSourceQueueSpec.scala | 20 +-
.../stream/scaladsl/CancellationStrategySpec.scala | 3 +-
.../pekko/stream/scaladsl/CompressionSpec.scala | 3 +-
.../scaladsl/CoupledTerminationFlowSpec.scala | 8 +-
.../stream/scaladsl/EagerFutureSinkSpec.scala | 193 ++
.../pekko/stream/scaladsl/FlowAlsoToAllSpec.scala | 8 +-
.../pekko/stream/scaladsl/FlowAlsoToSpec.scala | 288 ++
.../pekko/stream/scaladsl/FlowBatchSpec.scala | 275 ++
.../stream/scaladsl/FlowCollectFirstSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowCollectSpec.scala | 2 +-
.../stream/scaladsl/FlowCollectWhileSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowCompileSpec.scala | 32 +-
.../stream/scaladsl/FlowConcatAllLazySpec.scala | 10 +-
.../pekko/stream/scaladsl/FlowConcatAllSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowConcatSpec.scala | 323 ++-
.../pekko/stream/scaladsl/FlowDelaySpec.scala | 148 +-
.../pekko/stream/scaladsl/FlowDetacherSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowDispatcherSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowDoOnCancelSpec.scala | 118 +
.../pekko/stream/scaladsl/FlowDoOnFirstSpec.scala | 126 +
.../stream/scaladsl/FlowDropRepeatedSpec.scala | 12 +-
.../pekko/stream/scaladsl/FlowDropWhileSpec.scala | 8 +-
.../pekko/stream/scaladsl/FlowExpandSpec.scala | 199 +-
.../stream/scaladsl/FlowExtrapolateSpec.scala | 110 +-
.../pekko/stream/scaladsl/FlowFilterSpec.scala | 9 +-
.../FlowFlatMapConcatParallelismSpec.scala | 89 +-
.../stream/scaladsl/FlowFlatMapPrefixSpec.scala | 18 +-
.../stream/scaladsl/FlowFlattenMergeSpec.scala | 183 +-
.../pekko/stream/scaladsl/FlowFromFutureSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowGroupBySpec.scala | 39 +-
.../FlowGroupedAdjacentByWeightedSpec.scala | 101 +-
.../stream/scaladsl/FlowGroupedWeightedSpec.scala | 8 +-
.../stream/scaladsl/FlowGroupedWithinSpec.scala | 130 +-
.../pekko/stream/scaladsl/FlowIdleInjectSpec.scala | 42 +
.../stream/scaladsl/FlowInterleaveAllSpec.scala | 8 +-
.../stream/scaladsl/FlowIntersperseSpec.scala | 14 +-
.../pekko/stream/scaladsl/FlowIteratorSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowJoinSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowKillSwitchSpec.scala | 37 +-
.../stream/scaladsl/FlowLimitWeightedSpec.scala | 8 +-
.../scaladsl/FlowMapAsyncPartitionedSpec.scala | 637 ++++
.../pekko/stream/scaladsl/FlowMapAsyncSpec.scala | 72 +-
.../scaladsl/FlowMapAsyncUnorderedSpec.scala | 78 +-
.../pekko/stream/scaladsl/FlowMapConcatSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowMapErrorSpec.scala | 10 +-
.../stream/scaladsl/FlowMapWithResourceSpec.scala | 68 +-
.../pekko/stream/scaladsl/FlowMergeAllSpec.scala | 4 +-
.../pekko/stream/scaladsl/FlowMonitorSpec.scala | 14 +-
.../pekko/stream/scaladsl/FlowOnCompleteSpec.scala | 2 +-
.../stream/scaladsl/FlowOnErrorContinueSpec.scala | 99 +
.../pekko/stream/scaladsl/FlowOrElseSpec.scala | 3 +-
.../stream/scaladsl/FlowPrefixAndTailSpec.scala | 41 +-
.../pekko/stream/scaladsl/FlowRecoverSpec.scala | 10 +-
.../stream/scaladsl/FlowRecoverWithSpec.scala | 466 ++-
.../pekko/stream/scaladsl/FlowScanAsyncSpec.scala | 36 +-
.../pekko/stream/scaladsl/FlowScanSpec.scala | 13 +-
.../pekko/stream/scaladsl/FlowSlidingSpec.scala | 11 +-
.../apache/pekko/stream/scaladsl/FlowSpec.scala | 82 +-
.../pekko/stream/scaladsl/FlowSplitAfterSpec.scala | 6 +-
.../pekko/stream/scaladsl/FlowSplitWhenSpec.scala | 8 +-
.../scaladsl/FlowStatefulMapConcatSpec.scala | 8 +-
.../stream/scaladsl/FlowStatefulMapSpec.scala | 141 +-
.../pekko/stream/scaladsl/FlowSwitchSpec.scala | 18 +-
.../pekko/stream/scaladsl/FlowTakeSpec.scala | 2 +-
.../pekko/stream/scaladsl/FlowTakeWhileSpec.scala | 8 +-
.../pekko/stream/scaladsl/FlowThrottleSpec.scala | 79 +-
.../stream/scaladsl/FlowWatchTerminationSpec.scala | 17 +-
.../stream/scaladsl/FlowWithContextSpec.scala | 152 +-
.../scaladsl/FlowWithContextThrottleSpec.scala | 16 +-
.../stream/scaladsl/FlowZipWithIndexSpec.scala | 10 +-
.../pekko/stream/scaladsl/FlowZipWithSpec.scala | 41 +-
.../apache/pekko/stream/scaladsl/FramingSpec.scala | 6 +-
.../stream/scaladsl/GraphBackedFlowSpec.scala | 10 +-
.../pekko/stream/scaladsl/GraphBalanceSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphBroadcastSpec.scala | 55 +-
.../pekko/stream/scaladsl/GraphConcatSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphMatValueSpec.scala | 2 +-
.../stream/scaladsl/GraphMergeLatestSpec.scala | 18 +-
.../stream/scaladsl/GraphMergePreferredSpec.scala | 2 +-
.../scaladsl/GraphMergePrioritizedSpec.scala | 2 +-
.../stream/scaladsl/GraphMergeSequenceSpec.scala | 2 +-
.../stream/scaladsl/GraphMergeSortedSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphMergeSpec.scala | 2 +-
.../stream/scaladsl/GraphOpsIntegrationSpec.scala | 6 +-
.../pekko/stream/scaladsl/GraphUnzipWithSpec.scala | 12 +-
.../pekko/stream/scaladsl/GraphWireTapSpec.scala | 8 +-
.../pekko/stream/scaladsl/GraphZipLatestSpec.scala | 2 +-
.../stream/scaladsl/GraphZipLatestWithSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipNSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipSpec.scala | 2 +-
.../pekko/stream/scaladsl/GraphZipWithNSpec.scala | 46 +-
.../pekko/stream/scaladsl/GraphZipWithSpec.scala | 7 +-
.../org/apache/pekko/stream/scaladsl/HubSpec.scala | 154 +-
.../pekko/stream/scaladsl/JsonFramingSpec.scala | 35 +-
.../pekko/stream/scaladsl/LazySourceSpec.scala | 18 +-
.../pekko/stream/scaladsl/QueueSinkSpec.scala | 2 +-
.../pekko/stream/scaladsl/QueueSourceSpec.scala | 30 +-
.../apache/pekko/stream/scaladsl/RestartSpec.scala | 96 +-
.../pekko/stream/scaladsl/RetryFlowSpec.scala | 38 +-
.../stream/scaladsl/SinkAsJavaStreamSpec.scala | 5 +-
.../apache/pekko/stream/scaladsl/SinkSpec.scala | 75 +-
.../pekko/stream/scaladsl/SourceSinkSpec.scala | 87 +
.../apache/pekko/stream/scaladsl/SourceSpec.scala | 413 ++-
.../stream/scaladsl/SourceWithContextSpec.scala | 163 +-
.../pekko/stream/scaladsl/StageActorRefSpec.scala | 120 +-
.../stream/scaladsl/StreamConvertersSpec.scala | 4 +-
.../pekko/stream/scaladsl/StreamRefsSpec.scala | 82 +-
.../SubstreamSubscriptionTimeoutSpec.scala | 6 +-
.../pekko/stream/scaladsl/TakeLastSinkSpec.scala | 10 +-
.../stream/scaladsl/TlsEngineSelectionSpec.scala | 31 +-
.../scaladsl/UnfoldResourceAsyncSourceSpec.scala | 41 +-
.../stream/scaladsl/UnfoldResourceSourceSpec.scala | 77 +-
.../stream/scaladsl/WithContextUsageSpec.scala | 13 +-
.../stream/snapshot/MaterializerStateSpec.scala | 2 +-
.../pekko/stream/MapAsyncPartitionedSpec.scala | 64 +-
.../pekko/stream/typed/javadsl/package-info.java | 15 +-
.../pekko/stream/typed/javadsl/ActorFlow.scala | 33 +-
.../pekko/stream/typed/javadsl/ActorSource.scala | 6 +-
.../pekko/stream/typed/scaladsl/ActorFlow.scala | 31 +-
.../pekko/stream/typed/scaladsl/ActorSource.scala | 6 +-
.../typed/ActorSourceWithBackpressureExample.java | 18 +-
.../javadsl/CustomGuardianAndMaterializerTest.java | 19 +-
.../stream/typed/ActorSourceSinkExample.scala | 8 +-
.../typed/scaladsl/ActorSourceSinkSpec.scala | 4 +-
.../typed/scaladsl/MaterializerForTypedSpec.scala | 4 +-
.../pekko/stream/typed/scaladsl/PubSubSpec.scala | 1 +
.../scaladsl/ZipLatestWithApply.scala.template | 2 +-
.../stream/scaladsl/ZipWithApply.scala.template | 21 +-
.../org/apache/pekko/stream/StreamRefMessages.java | 241 +-
.../pekko/stream/javadsl/FramingTruncation.java | 2 +-
.../pekko/stream/javadsl/JavaFlowSupport.java | 9 +-
.../apache/pekko/stream/javadsl/package-info.java | 15 +-
...-subsource-and-subflow-final.backwards.excludes | 17 +
.../optimized-mandatory-attributes.excludes | 9 +-
.../pr-2916-boundary-event-allocation.excludes | 36 +
.../remove-dead-actorprocessor.excludes | 26 +
...emove-deprecated-materializer-settings.excludes | 31 +-
.../remove-deprecated-methods.excludes | 8 +-
.../remove-fanout-processor.excludes | 6 +-
.../remove-fanout-publisher-sink.excludes | 4 +-
.../remove-gunzip.excludes | 7 +-
.../remove-internal-unzip.excludes | 5 +-
.../remove-substream-cancel-strategy.excludes | 31 +-
stream/src/main/resources/reference.conf | 29 +-
.../apache/pekko/stream/ActorMaterializer.scala | 125 +-
.../scala/org/apache/pekko/stream/Attributes.scala | 168 +-
.../scala/org/apache/pekko/stream/FanInShape.scala | 12 +-
.../org/apache/pekko/stream/FanOutShape.scala | 12 +-
.../main/scala/org/apache/pekko/stream/Graph.scala | 2 +-
.../scala/org/apache/pekko/stream/KillSwitch.scala | 10 +-
.../apache/pekko/stream/MapAsyncPartitioned.scala | 62 +-
.../org/apache/pekko/stream/QueueOfferResult.scala | 2 +-
.../org/apache/pekko/stream/RestartSettings.scala | 16 +-
.../main/scala/org/apache/pekko/stream/Shape.scala | 55 +-
.../apache/pekko/stream/StreamRefSettings.scala | 70 -
.../pekko/stream/SubstreamCancelStrategy.scala | 57 -
.../apache/pekko/stream/SystemMaterializer.scala | 13 +-
.../apache/pekko/stream/TypePreservingFanIn.scala | 48 +
.../apache/pekko/stream/TypePreservingFanOut.scala | 44 +
.../apache/pekko/stream/UniformFanInShape.scala | 2 +-
.../apache/pekko/stream/impl/ActorProcessor.scala | 110 +-
.../apache/pekko/stream/impl/ActorPublisher.scala | 12 +-
.../stream/impl/ActorRefBackpressureSource.scala | 3 +-
.../pekko/stream/impl/ActorRefSinkStage.scala | 2 +-
.../apache/pekko/stream/impl/ActorRefSource.scala | 176 +-
.../pekko/stream/impl/CompletedPublishers.scala | 6 +-
.../stream/impl/ExposedPublisherReceive.scala | 43 -
.../apache/pekko/stream/impl/FailedConcat.scala | 60 +
.../apache/pekko/stream/impl/FailedSource.scala | 5 +-
.../scala/org/apache/pekko/stream/impl/FanIn.scala | 32 +-
.../org/apache/pekko/stream/impl/FanOut.scala | 38 +-
.../apache/pekko/stream/impl/FanoutProcessor.scala | 183 --
.../stream/impl/FanoutPublisherBridgeStage.scala | 247 ++
.../apache/pekko/stream/impl/FutureConcat.scala | 100 +
.../apache/pekko/stream/impl/IterableConcat.scala | 108 +
.../stream/impl/JavaFlowAndRsConverters.scala | 8 +-
.../pekko/stream/impl/JavaStreamConcat.scala | 80 +
.../pekko/stream/impl/JavaStreamSource.scala | 10 +-
.../pekko/stream/impl/JsonObjectParser.scala | 14 +-
.../org/apache/pekko/stream/impl/MaybeSource.scala | 4 +-
.../impl/PhasedFusingActorMaterializer.scala | 92 +-
.../org/apache/pekko/stream/impl/QueueSource.scala | 7 +-
.../apache/pekko/stream/impl/RepeatConcat.scala | 59 +
.../impl/ResizableMultiReaderRingBuffer.scala | 8 +-
.../org/apache/pekko/stream/impl/SetupStage.scala | 141 +-
.../pekko/stream/impl/SinkholeSubscriber.scala | 2 +-
.../scala/org/apache/pekko/stream/impl/Sinks.scala | 164 +-
.../org/apache/pekko/stream/impl/Stages.scala | 7 +
.../apache/pekko/stream/impl/StreamLayout.scala | 32 +-
.../stream/impl/StreamSubscriptionTimeout.scala | 12 +-
.../pekko/stream/impl/SubscriberManagement.scala | 18 +-
.../org/apache/pekko/stream/impl/Throttle.scala | 19 +-
.../org/apache/pekko/stream/impl/Timers.scala | 25 +-
.../pekko/stream/impl/TraversalBuilder.scala | 121 +-
.../org/apache/pekko/stream/impl/Unfold.scala | 12 +-
.../pekko/stream/impl/UnfoldResourceSource.scala | 5 +-
.../stream/impl/UnfoldResourceSourceAsync.scala | 23 +-
.../stream/impl/fusing/ActorGraphInterpreter.scala | 414 ++-
.../stream/impl/fusing/AggregateWithBoundary.scala | 122 +-
.../pekko/stream/impl/fusing/CountSink.scala | 66 +
.../pekko/stream/impl/fusing/DoOnCancel.scala | 59 +
.../pekko/stream/impl/fusing/DoOnFirst.scala | 77 +
.../pekko/stream/impl/fusing/DropRepeated.scala | 6 +-
.../pekko/stream/impl/fusing/FlattenConcat.scala | 177 +-
.../pekko/stream/impl/fusing/FutureFlow.scala | 6 +-
.../stream/impl/fusing/GraphInterpreter.scala | 156 +-
.../pekko/stream/impl/fusing/GraphStages.scala | 34 +-
.../impl/fusing/GroupedAdjacentByWeighted.scala | 32 +-
.../pekko/stream/impl/fusing/InflightSources.scala | 181 ++
.../pekko/stream/impl/fusing/IterableSource.scala | 5 +-
.../{IterableSource.scala => IteratorSource.scala} | 56 +-
.../stream/impl/fusing/LazyFutureSource.scala | 4 +-
.../pekko/stream/impl/fusing/MapConcat.scala | 2 -
.../org/apache/pekko/stream/impl/fusing/Ops.scala | 435 ++-
.../pekko/stream/impl/fusing/RangeSource.scala | 66 +
.../pekko/stream/impl/fusing/SourceSink.scala | 121 +
.../pekko/stream/impl/fusing/StreamOfStreams.scala | 204 +-
.../apache/pekko/stream/impl/fusing/Switch.scala | 2 +-
.../pekko/stream/impl/io/ByteStringParser.scala | 44 +-
.../pekko/stream/impl/io/FileOutputStage.scala | 2 +-
.../stream/impl/io/InputStreamSinkStage.scala | 10 +-
.../pekko/stream/impl/io/InputStreamSource.scala | 2 +-
.../stream/impl/io/OutputStreamGraphStage.scala | 2 +-
.../stream/impl/io/OutputStreamSourceStage.scala | 2 +-
.../org/apache/pekko/stream/impl/io/TLSActor.scala | 68 +-
.../apache/pekko/stream/impl/io/TcpStages.scala | 36 +-
.../pekko/stream/impl/io/TlsEngineHelpers.scala | 74 +
.../pekko/stream/impl/io/TlsGraphStage.scala | 1103 +++++++
.../impl/io/compression/CompressionUtils.scala | 10 +-
.../io/compression/DeflateDecompressorBase.scala | 2 +-
.../org/apache/pekko/stream/impl/package.scala | 18 +-
.../pekko/stream/impl/streamref/SinkRefImpl.scala | 70 +-
.../stream/impl/streamref/SourceRefImpl.scala | 44 +-
.../impl/streamref/StreamRefDefaultSettings.scala | 27 +
.../impl/streamref/StreamRefSettingsImpl.scala | 41 -
.../stream/impl/streamref/StreamRefsMaster.scala | 4 +-
.../org/apache/pekko/stream/javadsl/BidiFlow.scala | 6 +-
.../apache/pekko/stream/javadsl/Compression.scala | 44 +-
.../pekko/stream/javadsl/DelayStrategy.scala | 6 +-
.../org/apache/pekko/stream/javadsl/FileIO.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Flow.scala | 619 ++--
.../pekko/stream/javadsl/FlowWithContext.scala | 185 +-
.../org/apache/pekko/stream/javadsl/Graph.scala | 96 +-
.../org/apache/pekko/stream/javadsl/Hub.scala | 18 +-
.../apache/pekko/stream/javadsl/MergeLatest.scala | 3 +-
.../org/apache/pekko/stream/javadsl/Queue.scala | 8 +-
.../apache/pekko/stream/javadsl/RestartFlow.scala | 4 +-
.../apache/pekko/stream/javadsl/RestartSink.scala | 2 +-
.../pekko/stream/javadsl/RestartSource.scala | 4 +-
.../apache/pekko/stream/javadsl/RetryFlow.scala | 11 +-
.../org/apache/pekko/stream/javadsl/Sink.scala | 118 +-
.../org/apache/pekko/stream/javadsl/Source.scala | 707 +++--
.../pekko/stream/javadsl/SourceWithContext.scala | 182 +-
.../javadsl/StatefulMapConcatAccumulator.scala | 9 +-
.../pekko/stream/javadsl/StreamConverters.scala | 23 +-
.../org/apache/pekko/stream/javadsl/SubFlow.scala | 570 +++-
.../apache/pekko/stream/javadsl/SubSource.scala | 565 +++-
.../org/apache/pekko/stream/javadsl/Tcp.scala | 29 +-
.../org/apache/pekko/stream/javadsl/package.scala | 2 +-
.../apache/pekko/stream/scaladsl/BidiFlow.scala | 4 +-
.../apache/pekko/stream/scaladsl/Compression.scala | 54 +-
.../pekko/stream/scaladsl/DelayStrategy.scala | 2 +-
.../org/apache/pekko/stream/scaladsl/FileIO.scala | 8 +-
.../org/apache/pekko/stream/scaladsl/Flow.scala | 580 ++--
.../pekko/stream/scaladsl/FlowWithContext.scala | 14 +-
.../pekko/stream/scaladsl/FlowWithContextOps.scala | 279 +-
.../org/apache/pekko/stream/scaladsl/Framing.scala | 6 +-
.../org/apache/pekko/stream/scaladsl/Graph.scala | 245 +-
.../org/apache/pekko/stream/scaladsl/Hub.scala | 154 +-
.../pekko/stream/scaladsl/JavaFlowSupport.scala | 2 +-
.../org/apache/pekko/stream/scaladsl/Queue.scala | 22 +-
.../apache/pekko/stream/scaladsl/RestartFlow.scala | 16 +-
.../apache/pekko/stream/scaladsl/RestartSink.scala | 4 +-
.../pekko/stream/scaladsl/RestartSource.scala | 6 +-
.../apache/pekko/stream/scaladsl/RetryFlow.scala | 2 +-
.../org/apache/pekko/stream/scaladsl/Sink.scala | 125 +-
.../org/apache/pekko/stream/scaladsl/Source.scala | 298 +-
.../pekko/stream/scaladsl/SourceWithContext.scala | 12 +-
.../scaladsl/StatefulMapConcatAccumulator.scala | 8 +-
.../pekko/stream/scaladsl/StreamConverters.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/SubFlow.scala | 4 +-
.../org/apache/pekko/stream/scaladsl/TLS.scala | 52 +-
.../org/apache/pekko/stream/scaladsl/Tcp.scala | 21 +-
.../org/apache/pekko/stream/scaladsl/package.scala | 5 +-
.../stream/serialization/StreamRefSerializer.scala | 36 +-
.../org/apache/pekko/stream/stage/GraphStage.scala | 350 ++-
.../apache/pekko/stream/stage/StageLogging.scala | 6 +-
.../pekko/testkit/CallingThreadDispatcher.scala | 6 +-
.../testkit/ExplicitlyTriggeredScheduler.scala | 11 +-
.../org/apache/pekko/testkit/TestActorRef.scala | 3 +-
.../apache/pekko/testkit/TestEventListener.scala | 10 +-
.../apache/pekko/testkit/TestJavaSerializer.scala | 13 +-
.../scala/org/apache/pekko/testkit/TestKit.scala | 28 +-
.../apache/pekko/testkit/TestKitExtension.scala | 4 +-
.../org/apache/pekko/testkit/TestKitUtils.scala | 12 +-
.../apache/pekko/testkit/javadsl/EventFilter.scala | 10 +-
.../org/apache/pekko/testkit/javadsl/TestKit.scala | 97 +-
.../scala/org/apache/pekko/testkit/package.scala | 2 -
.../testkit/PekkoJUnitActorSystemResource.java | 9 +-
.../PekkoJUnitJupiterActorSystemResource.java | 202 ++
.../pekko/testkit/javadsl/TestKitApiTest.java | 2 +
.../apache/pekko/testkit/DefaultTimeoutSpec.scala | 4 +-
.../apache/pekko/testkit/ImplicitSenderSpec.scala | 4 +-
.../scala/org/apache/pekko/testkit/PekkoSpec.scala | 31 +-
.../org/apache/pekko/testkit/PekkoSpecSpec.scala | 16 +-
.../apache/pekko/testkit/TestActorRefSpec.scala | 6 +-
.../org/apache/pekko/testkit/TestProbeSpec.scala | 4 +-
.../apache/pekko/testkit/WithLogCapturing.scala | 4 +-
.../testkit/metrics/FileDescriptorMetricSet.scala | 4 +-
.../apache/pekko/testkit/metrics/MetricsKit.scala | 15 +-
.../pekko/testkit/metrics/MetricsKitOps.scala | 3 +-
.../pekko/testkit/metrics/MetricsKitSpec.scala | 3 +-
.../metrics/reporter/PekkoConsoleReporter.scala | 10 +-
2593 files changed, 70636 insertions(+), 30722 deletions(-)
copy .github/{workflows/verify-jdk9-classes.sh => scripts/resolve-scala-version.sh} (50%)
copy .github/workflows/{nightly-1.1-builds.yml => nightly-1.3-builds.yml} (83%)
copy .github/workflows/{nightly-1.1-builds.yml => nightly-1.4-builds.yml} (83%)
copy .github/workflows/{nightly-1.1-builds.yml => nightly-1.5-builds.yml} (84%)
copy .github/workflows/{nightly-1.1-builds.yml => nightly-1.6-builds.yml} (84%)
copy .github/workflows/{nightly-1.1-builds.yml => nightly-1.7-builds.yml} (84%)
copy .github/workflows/{publish-1.2-docs.yml => publish-1.3-docs.yml} (82%)
copy .github/workflows/{publish-1.1-nightly.yml => publish-1.3-nightly.yml} (81%)
copy .github/workflows/{publish-1.2-docs.yml => publish-1.4-docs.yml} (82%)
copy .github/workflows/{publish-1.1-nightly.yml => publish-1.4-nightly.yml} (83%)
copy .github/workflows/{publish-1.2-docs.yml => publish-1.5-docs.yml} (82%)
copy .github/workflows/{publish-1.2-nightly.yml => publish-1.5-nightly.yml} (81%)
copy .github/workflows/{publish-1.2-docs.yml => publish-1.6-docs.yml} (82%)
copy .github/workflows/{publish-1.1-nightly.yml => publish-1.6-nightly.yml} (81%)
copy .github/workflows/{publish-1.1-nightly.yml => publish-1.7-nightly.yml} (83%)
copy .github/workflows/{publish-1.2-docs.yml => publish-2.0-docs.yml} (79%)
delete mode 100644 .github/workflows/scala-steward.yml
delete mode 100644 .github/workflows/scala3-build.yml
create mode 100644 .github/workflows/stage-release-candidate.yml
create mode 100644 AGENTS.md
create mode 100644 CLAUDE.md
copy actor-testkit-typed/src/main/java/org/apache/pekko/actor/testkit/typed/annotations/{JUnit5TestKit.java => JUnitJupiterTestKit.java} (95%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => actor-testkit-typed/src/main/mima-filters/2.0.x.backwards.excludes/add-ask-behavior-methods.excludes (59%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => actor-testkit-typed/src/main/mima-filters/2.0.x.backwards.excludes/renamed-methods.excludes (86%)
copy actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/{JUnit5TestKitBuilder.scala => JUnitJupiterTestKitBuilder.scala} (82%)
copy actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/{TestKitJUnit5Extension.scala => TestKitJUnitJupiterExtension.scala} (82%)
rename actor-testkit-typed/src/test/java/jdocs/org/apache/pekko/actor/testkit/typed/javadsl/{JUnit5IntegrationExampleTest.java => JUnitJupiterIntegrationExampleTest.java} (79%)
rename actor-testkit-typed/src/test/java/org/apache/pekko/actor/testkit/typed/javadsl/{ActorTestKitJUnit5Test.java => ActorTestKitJUnitJupiterTest.java} (77%)
copy actor-testkit-typed/src/test/scala/org/apache/pekko/actor/testkit/typed/scaladsl/{JUnit5TestKitBuilderSpec.scala => JUnitJupiterTestKitBuilderSpec.scala} (67%)
delete mode 100755 actor-tests/src/test/bind/etc/db.0
delete mode 100755 actor-tests/src/test/bind/etc/db.127
delete mode 100755 actor-tests/src/test/bind/etc/db.255
mode change 100755 => 100644 actor-tests/src/test/bind/etc/db.bar.example
delete mode 100755 actor-tests/src/test/bind/etc/db.empty
mode change 100755 => 100644 actor-tests/src/test/bind/etc/db.foo.test
delete mode 100755 actor-tests/src/test/bind/etc/db.local
delete mode 100755 actor-tests/src/test/bind/etc/db.root
delete mode 100755 actor-tests/src/test/bind/etc/named.conf
delete mode 100755 actor-tests/src/test/bind/etc/named.conf.default-zones
mode change 100755 => 100644 actor-tests/src/test/bind/etc/named.conf.local
mode change 100755 => 100644 actor-tests/src/test/bind/etc/named.conf.options
delete mode 100755 actor-tests/src/test/bind/etc/rndc.key
mode change 100755 => 100644 actor-tests/src/test/bind/etc/zones.rfc1918
create mode 100644 actor-tests/src/test/java/org/apache/pekko/actor/AbstractActorPreRestartFinalTest.java
delete mode 100644 actor-tests/src/test/java/org/apache/pekko/util/JavaConverterScala3InlineTest.java
copy actor-tests/src/test/scala-jdk21-only/org/apache/pekko/dispatch/{ForkJoinPoolVirtualThreadSpec.scala => ThreadPoolVirtualThreadSpec.scala} (59%)
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/actor/AbstractActorPreRestartFinalSpec.scala
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/dispatch/ForkJoinExecutorConfiguratorSpec.scala
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/io/InetSocketOptionSpec.scala
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/io/UnsynchronizedByteArrayInputStreamSpec.scala
rename actor-tests/src/test/{scala-2.13+ => scala}/org/apache/pekko/util/ByteStringBuilderScala213PlusSpec.scala (100%)
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/util/SWARUtilSpec.scala
delete mode 100644 actor-tests/src/test/scala/org/apache/pekko/util/Scala212CompatTest.scala
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/util/ScheduledClockSpec.scala
create mode 100644 actor-tests/src/test/scala/org/apache/pekko/util/TestClock.scala
copy actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/{OOIntroTest.java => OnMessageIntroTest.java} (55%)
create mode 100644 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/CancelReceiveTimeoutSpec.scala
create mode 100644 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/adapter/PropsAdapterSpec.scala
delete mode 100644 actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/adpater/PropsAdapterSpec.scala
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => actor-typed/src/main/mima-filters/1.3.x.backwards.excludes/actorsystem-close.excludes (76%)
delete mode 100644 actor-typed/src/main/scala-2.12/org/apache/pekko/actor/typed/internal/receptionist/Platform.scala
rename actor/src/main/scala-3/org/apache/pekko/compat/PartialFunction.scala => actor-typed/src/main/scala/org/apache/pekko/actor/typed/internal/CachedProps.scala (51%)
create mode 100644 actor-typed/src/main/scala/org/apache/pekko/actor/typed/javadsl/AbstractMatchingBehavior.scala
create mode 100644 actor/src/main/java/org/apache/pekko/io/UnsynchronizedByteArrayInputStream.java
delete mode 100644 actor/src/main/java/org/apache/pekko/util/ClassContext.java
create mode 100644 actor/src/main/java/org/apache/pekko/util/OptionalUtil.java
copy actor/src/main/mima-filters/{1.1.x.backwards.excludes/backoff-calculation.excludes => 1.2.x.backwards.excludes/bytestring-indexOf-overload.excludes} (83%)
copy actor/src/main/mima-filters/{1.1.x.backwards.excludes/backoff-calculation.excludes => 1.3.x.backwards.excludes/actorsystem-close.excludes} (70%)
copy stream-testkit/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes => actor/src/main/mima-filters/2.0.x.backwards.excludes/add-scheduled-clock.excludes (73%)
copy actor/src/main/mima-filters/{1.1.x.backwards.excludes => 2.0.x.backwards.excludes}/backoff-calculation.excludes (82%)
copy .github/workflows/verify-jdk9-classes.sh => actor/src/main/mima-filters/2.0.x.backwards.excludes/fsm-transition-listeners.excludes (69%)
copy actor/src/main/mima-filters/{1.1.x.backwards.excludes/backoff-calculation.excludes => 2.0.x.backwards.excludes/function-converters.excludes} (74%)
delete mode 100644 actor/src/main/mima-filters/2.0.x.backwards.excludes/option-converters.excludes
create mode 100644 actor/src/main/mima-filters/2.0.x.backwards.excludes/remove-scala-2.12-support.excludes
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/compat/Future.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/compat/PartialFunction.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/dispatch/internal/ScalaBatchable.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/ByteIterator.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/ByteString.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/FunctionConverters.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/FutureConverters.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/OptionConverters.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/ccompat/CompatImpl.scala
delete mode 100644 actor/src/main/scala-2.12/org/apache/pekko/util/ccompat/package.scala
delete mode 100644 actor/src/main/scala-2.13+/org/apache/pekko/compat/Future.scala
delete mode 100644 actor/src/main/scala-2.13+/org/apache/pekko/util/ccompat/ccompatUsedUntil213.scala
delete mode 100644 actor/src/main/scala-2.13+/org/apache/pekko/util/ccompat/package.scala
delete mode 100644 actor/src/main/scala-2.13/org/apache/pekko/compat/PartialFunction.scala
delete mode 100644 actor/src/main/scala-2.13/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644 actor/src/main/scala-2.13/org/apache/pekko/util/ByteString.scala
delete mode 100644 actor/src/main/scala-2.13/org/apache/pekko/util/FutureConverters.scala
delete mode 100644 actor/src/main/scala-2.13/org/apache/pekko/util/OptionConverters.scala
delete mode 100644 actor/src/main/scala-2/org/apache/pekko/util/JavaDurationConverters.scala
delete mode 100644 actor/src/main/scala-3/org/apache/pekko/dispatch/internal/SameThreadExecutionContext.scala
delete mode 100644 actor/src/main/scala-3/org/apache/pekko/dispatch/internal/ScalaBatchable.scala
delete mode 100644 actor/src/main/scala-3/org/apache/pekko/util/ByteString.scala
delete mode 100644 actor/src/main/scala-3/org/apache/pekko/util/FutureConverters.scala
delete mode 100644 actor/src/main/scala-3/org/apache/pekko/util/JavaDurationConverters.scala
delete mode 100644 actor/src/main/scala-3/org/apache/pekko/util/OptionConverters.scala
rename actor/src/main/{scala-2.13 => scala}/org/apache/pekko/dispatch/internal/ScalaBatchable.scala (100%)
create mode 100644 actor/src/main/scala/org/apache/pekko/util/ByteString.scala
create mode 100644 actor/src/main/scala/org/apache/pekko/util/Clock.scala
create mode 100644 actor/src/main/scala/org/apache/pekko/util/SWARUtil.scala
delete mode 100644 actor/src/main/scala/org/apache/pekko/util/Unused.scala
copy {stream-tests/src/test => bench-jmh/src/main}/resources/keystore (100%)
copy {stream-tests/src/test => bench-jmh/src/main}/resources/truststore (100%)
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/ActorGraphInterpreterBoundaryBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/ActorRefSourceBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/AsyncBoundaryThroughputBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/BroadcastHubBenchRunner.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/BroadcastHubBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/GraphStageConstructionBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/MaterializerWiringBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/RangeSourceBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/StageActorRefBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/stream/io/TlsBenchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/util/ByteStringParser_readNum_Benchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_concat3way_Benchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_indexOfSlice_Benchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_lastIndexOfSlice_Benchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_putInt_Benchmark.scala
create mode 100644 bench-jmh/src/main/scala/org/apache/pekko/util/ByteString_startEnd_Benchmark.scala
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => cluster-sharding-typed/src/main/mima-filters/2.0.x.backwards.excludes/dynamic-scaling.excludes (63%)
copy stream-testkit/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes => cluster-sharding-typed/src/main/mima-filters/2.0.x.backwards.excludes/remove-old-passivation-strategy.excludes (80%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => cluster-sharding-typed/src/main/mima-filters/2.0.x.backwards.excludes/throttle-keep-alive-messages.excludes (81%)
create mode 100644 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessCommand.scala
rename actor/src/main/scala-2.12/org/apache/pekko/util/ccompat/ccompatUsedUntil213.scala => cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/internal/ClusterShardingTypedSerializable.scala (51%)
create mode 100644 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/internal/ShardedDaemonProcessCoordinator.scala
create mode 100644 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/internal/ShardedDaemonProcessId.scala
create mode 100644 cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/internal/ShardedDaemonProcessState.scala
create mode 100644 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/AccountExamplePersistenceProbeDocTest.java
create mode 100644 cluster-sharding-typed/src/test/java/jdocs/org/apache/pekko/cluster/sharding/typed/ConsistentHashingShardAllocationCompileOnlyTest.java
create mode 100644 cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/AccountExamplePersistenceProbeDocSpec.scala
create mode 100644 cluster-sharding-typed/src/test/scala/docs/org/apache/pekko/cluster/sharding/typed/ConsistentHashingShardAllocationCompileOnlySpec.scala
create mode 100644 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/internal/ShardedDaemonProcessIdSpec.scala
create mode 100644 cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/internal/ShardedDaemonProcessStateSpec.scala
rename .github/workflows/verify-jdk9-classes.sh => cluster-sharding/src/main/mima-filters/2.0.x.backwards.excludes/consistent-hashing-allocation.excludes (54%)
copy cluster-sharding/src/main/mima-filters/2.0.x.backwards.excludes/{remove-deprecated-methods.excludes => remove-old-passivation-strategy.excludes} (73%)
create mode 100644 cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ConsistentHashingShardAllocationStrategy.scala
copy cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/internal/{AbstractLeastShardAllocationStrategy.scala => ClusterShardAllocationMixin.scala} (63%)
create mode 100644 cluster-sharding/src/multi-jvm/scala/org/apache/pekko/cluster/sharding/ClusterShardingCoordinatorRoleSpec.scala
create mode 100644 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConsistentHashingShardAllocationStrategySpec.scala
create mode 100644 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ShardRegionDataTypesSpec.scala
create mode 100644 cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/StopShardsSpec.scala
delete mode 100644 cluster-typed/src/main/scala-2.12/org/apache/pekko/cluster/typed/internal/receptionist/ClusterReceptionistProtocol.scala
create mode 100644 cluster/src/multi-jvm/scala/org/apache/pekko/cluster/AppVersionSpec.scala
create mode 100644 distributed-data/src/main/mima-filters/2.0.x.backwards.excludes/crdt-expiry.excludes
create mode 100644 distributed-data/src/multi-jvm/scala/org/apache/pekko/cluster/ddata/WildcardSubscribeSpec.scala
create mode 100644 distributed-data/src/test/scala/org/apache/pekko/cluster/ddata/ReplicatorWildcardSubscriptionSpec.scala
create mode 100644 docs/src/main/java/docs/persistence/state/MyJavaStateStore.java
create mode 100644 docs/src/main/java/docs/persistence/state/MyJavaStateStoreProvider.java
create mode 100644 docs/src/main/paradox/durable-state/state-store-plugin.md
rename docs/src/main/paradox/images/{dispatcher-behaviour-on-bad-code.png => dispatcher-behavior-on-bad-code.png} (100%)
rename docs/src/main/paradox/images/{dispatcher-behaviour-on-good-code.png => dispatcher-behavior-on-good-code.png} (100%)
rename docs/src/main/paradox/project/{project-index.md => index.md} (83%)
create mode 100644 docs/src/main/paradox/release-notes/releases-1.3.md
create mode 100644 docs/src/main/paradox/release-notes/releases-1.4.md
create mode 100644 docs/src/main/paradox/release-notes/releases-1.5.md
create mode 100644 docs/src/main/paradox/release-notes/releases-1.6.md
create mode 100644 docs/src/main/paradox/release-notes/releases-2.0.md
create mode 100644 docs/src/main/paradox/remote-security.md
rename docs/src/main/paradox/stream/operators/Compression/{gunzip.md => gzipDecompress.md} (69%)
create mode 100644 docs/src/main/paradox/stream/operators/Sink/count.md
create mode 100644 docs/src/main/paradox/stream/operators/Sink/eagerCompletionStageSink.md
create mode 100644 docs/src/main/paradox/stream/operators/Sink/eagerFutureSink.md
create mode 100644 docs/src/main/paradox/stream/operators/Sink/source.md
create mode 100644 docs/src/main/paradox/stream/operators/Source-or-Flow/doOnCancel.md
create mode 100644 docs/src/main/paradox/stream/operators/Source-or-Flow/doOnFirst.md
create mode 100644 docs/src/main/paradox/stream/operators/Source-or-Flow/mapOption.md
create mode 100644 docs/src/main/paradox/stream/operators/Source-or-Flow/onErrorContinue.md
create mode 100644 docs/src/main/paradox/stream/operators/Source/fromOption.md
create mode 100644 docs/src/main/paradox/stream/operators/Source/items.md
create mode 100644 docs/src/main/scala/docs/persistence/state/MyStateStore.scala
copy docs/src/test/java/jdocs/stream/operators/{flow/DiMap.java => JavaCollectorDocExamples.java} (60%)
create mode 100644 docs/src/test/scala/docs/persistence/state/PersistenceStatePluginDocSpec.scala
rename stream/src/main/scala-2.12/org/apache/pekko/stream/javadsl/CollectionUtil.scala => docs/src/test/scala/docs/stream/operators/DoOnFirst.scala (62%)
rename stream/src/main/scala-3/org/apache/pekko/stream/javadsl/CollectionUtil.scala => docs/src/test/scala/docs/stream/operators/JavaCollectorDocExample.scala (60%)
create mode 100644 docs/src/test/scala/docs/stream/operators/MapOption.scala
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => persistence-query/src/main/java/org/apache/pekko/persistence/query/javadsl/package-info.java (70%)
create mode 100644 persistence-query/src/main/mima-filters/2.0.x.backwards.excludes/typed-event-envelope-tags.excludes
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventsBySliceFirehoseReadJournalProvider.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/internal/EventsBySliceFirehose.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/CurrentEventsByPersistenceIdStartingFromSnapshotQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/CurrentEventsByPersistenceIdTypedQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/CurrentEventsBySliceStartingFromSnapshotsQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsByPersistenceIdStartingFromSnapshotQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsByPersistenceIdTypedQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsBySliceFirehoseQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/javadsl/EventsBySliceStartingFromSnapshotsQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/CurrentEventsByPersistenceIdStartingFromSnapshotQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/CurrentEventsByPersistenceIdTypedQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/CurrentEventsBySliceStartingFromSnapshotsQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsByPersistenceIdStartingFromSnapshotQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsByPersistenceIdTypedQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsBySliceFirehoseQuery.scala
create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/scaladsl/EventsBySliceStartingFromSnapshotsQuery.scala
create mode 100644 persistence-query/src/test/scala/org/apache/pekko/persistence/query/TestClock.scala
create mode 100644 persistence-query/src/test/scala/org/apache/pekko/persistence/query/typed/EventEnvelopeSpec.scala
create mode 100644 persistence-query/src/test/scala/org/apache/pekko/persistence/query/typed/internal/EventsBySliceFirehoseSpec.scala
copy persistence-tck/src/main/scala/org/apache/pekko/persistence/japi/{snapshot/JavaSnapshotStoreSpec.scala => state/JavaDurableStateStoreSpec.scala} (64%)
create mode 100644 persistence-tck/src/main/scala/org/apache/pekko/persistence/state/DurableStateStoreSpec.scala
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => persistence-testkit/src/main/java/org/apache/pekko/persistence/testkit/javadsl/package-info.java (70%)
create mode 100644 persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/internal/PersistenceProbeImpl.scala
create mode 100644 persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/javadsl/PersistenceProbeBehavior.scala
create mode 100644 persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/query/internal/TypedEventsByPersistenceIdStage.scala
create mode 100644 persistence-testkit/src/main/scala/org/apache/pekko/persistence/testkit/scaladsl/PersistenceProbeBehavior.scala
create mode 100644 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/query/EventsByPersistenceIdTypedSpec.scala
create mode 100644 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/PersistenceProbeDurableStateSpec.scala
create mode 100644 persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/scaladsl/PersistenceProbeEventSourcedSpec.scala
copy stream/src/main/scala-2.13/org/apache/pekko/stream/javadsl/CollectionUtil.scala => persistence-testkit/src/test/scala/org/apache/pekko/persistence/testkit/state/scaladsl/PersistenceTestKitDurableStateStoreTCKSpec.scala (51%)
create mode 100644 persistence-typed-tests/src/test/java/org/apache/pekko/persistence/typed/state/javadsl/RuntimeDurableStateStoreTest.java
create mode 100644 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/scaladsl/EventSourcedBehaviorRetentionOnlyOneSnapshotSpec.scala
copy persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/{DurableStateBehaviorReplySpec.scala => DurableStateBehaviorSpec.scala} (59%)
create mode 100644 persistence-typed-tests/src/test/scala/org/apache/pekko/persistence/typed/state/scaladsl/RuntimeDurableStateStoreSpec.scala
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => persistence-typed/src/main/java/org/apache/pekko/persistence/typed/javadsl/package-info.java (70%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => persistence-typed/src/main/mima-filters/1.3.x.backwards.excludes/custom-stash.excludes (71%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => persistence-typed/src/main/mima-filters/2.0.x.backwards.excludes/durablestate-runtime-config.excludes (77%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => persistence-typed/src/main/mima-filters/2.0.x.backwards.excludes/external-replication.excludes (55%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => persistence-typed/src/main/mima-filters/2.0.x.backwards.excludes/tags-for-state.excludes (71%)
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => persistence/src/main/java/org/apache/pekko/persistence/journal/japi/package-info.java (70%)
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => persistence/src/main/java/org/apache/pekko/persistence/snapshot/japi/package-info.java (70%)
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => persistence/src/main/java/org/apache/pekko/persistence/state/javadsl/package-info.java (70%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => persistence/src/main/mima-filters/2.0.x.backwards.excludes/fsm-transition-listeners.excludes (78%)
create mode 100644 persistence/src/main/scala/org/apache/pekko/persistence/FilteredPayload.scala
create mode 100644 persistence/src/main/scala/org/apache/pekko/persistence/serialization/FilteredPayloadSerializer.scala
create mode 100644 persistence/src/test/scala/org/apache/pekko/persistence/serialization/FilteredPayloadSerializerSpec.scala
delete mode 100644 plugins/serialversion-remover-plugin/src/main/resources/plugin.properties
delete mode 100644 plugins/serialversion-remover-plugin/src/main/scala/org/apache/pekko/Plugin.scala
rename project/{CopyrightHeaderForJdk9.scala => CopyrightHeaderForJdk21.scala} (76%)
rename project/{Jdk9.scala => Jdk21.scala} (61%)
delete mode 100644 project/ProjectIndexGenerator.scala
rename project/{ScalaFixForJdk9Plugin.scala => ScalaFixForJdk21Plugin.scala} (70%)
delete mode 100644 project/VerifyJDK9Classes.scala
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => remote/src/main/mima-filters/2.0.x.backwards.excludes/future-lazy-vals.excludes (76%)
create mode 100644 remote/src/test/scala/org/apache/pekko/remote/ConfigSSLEngineProviderSpec.scala
create mode 100644 remote/src/test/scala/org/apache/pekko/remote/ReliableDeliverySupervisorSpec.scala
create mode 100644 remote/src/test/scala/org/apache/pekko/remote/artery/ActorSelectionQueueDistributionSpec.scala
create mode 100644 remote/src/test/scala/org/apache/pekko/remote/artery/tcp/ArteryConfigSSLEngineProviderSpec.scala
create mode 100644 remote/src/test/scala/org/apache/pekko/remote/transport/ThrottlerHandleSpec.scala
create mode 100644 remote/src/test/scala/org/apache/pekko/remote/transport/netty/NettySSLSupportSpec.scala
delete mode 100755 scripts/find-javadoc-error.pl
create mode 100644 serialization-jackson3/src/main/resources/reference.conf
create mode 100644 serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/ActorRefModule.scala
create mode 100644 serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/ActorSystemAccess.scala
create mode 100644 serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/AddressModule.scala
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/FiniteDurationModule.scala (63%)
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/JacksonMigration.scala (91%)
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/JacksonModule.scala (56%)
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/JacksonObjectMapperProvider.scala (55%)
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/JacksonSerializer.scala (92%)
create mode 100644 serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/PekkoJacksonModule.scala
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/PekkoSerializationModule.scala (64%)
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/StreamRefModule.scala (69%)
copy {serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3}/TypedActorRefModule.scala (68%)
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/MySerializable.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/SerializationDocTest.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v1/Customer.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v1/ItemAdded.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v1/OrderAdded.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v1withv2/ItemAddedMigration.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2a/Address.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2a/Customer.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2a/CustomerMigration.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2a/ItemAdded.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2a/OrderPlaced.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2a/OrderPlacedMigration.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2b/ItemAdded.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2b/ItemAddedMigration.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2c/ItemAdded.java
create mode 100644 serialization-jackson3/src/test/java/jdoc/org/apache/pekko/serialization/jackson3/v2c/ItemAddedMigration.java
create mode 100644 serialization-jackson3/src/test/java/org/apache/pekko/serialization/jackson3/JavaTestEventMigrationV2.java
create mode 100644 serialization-jackson3/src/test/java/org/apache/pekko/serialization/jackson3/JavaTestEventMigrationV2WithV3.java
create mode 100644 serialization-jackson3/src/test/java/org/apache/pekko/serialization/jackson3/JavaTestEventMigrationV3.java
create mode 100644 serialization-jackson3/src/test/java/org/apache/pekko/serialization/jackson3/JavaTestMessages.java
create mode 100644 serialization-jackson3/src/test/resources/reference.conf
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/CustomAdtSerializer.scala
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/SerializationDocSpec.scala
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v1/Customer.scala (53%)
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v1/ItemAdded.scala (53%)
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v1/OrderAdded.scala (53%)
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v1withv2/ItemAddedMigration.scala
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2a/Address.scala (53%)
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2a/Customer.scala (53%)
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2a/CustomerMigration.scala
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2a/ItemAdded.scala
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2a/OrderPlaced.scala (53%)
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2a/OrderPlacedMigration.scala
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2b/ItemAdded.scala (53%)
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2b/ItemAddedMigration.scala
copy remote/src/test/protobuf/ProtobufProtocolV3.proto => serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2c/ItemAdded.scala (53%)
create mode 100644 serialization-jackson3/src/test/scala/doc/org/apache/pekko/serialization/jackson3/v2c/ItemAddedMigration.scala
copy stream/src/main/java/org/apache/pekko/stream/javadsl/FramingTruncation.java => serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/CborSerializable.scala (58%)
copy {serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3}/JacksonFactorySpec.scala (64%)
copy {serialization-jackson/src/test/scala/org/apache/pekko/serialization/jackson => serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3}/JacksonSerializerSpec.scala (79%)
copy stream/src/main/java/org/apache/pekko/stream/javadsl/FramingTruncation.java => serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/JsonSerializable.scala (58%)
create mode 100644 serialization-jackson3/src/test/scala/org/apache/pekko/serialization/jackson3/ScalaTestEventMigration.scala
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => stream-testkit/src/main/java/org/apache/pekko/stream/testkit/javadsl/package-info.java (70%)
create mode 100644 stream-testkit/src/main/mima-filters/2.0.x.backwards.excludes/fix-java-unchecked-warnings.excludes
rename stream-tests-tck/src/test/{scala-jdk9-only => scala}/org/apache/pekko/stream/tck/IterablePublisherViaJavaFlowPublisherTest.scala (94%)
create mode 100644 stream-tests/src/test/java/org/apache/pekko/stream/StreamTestJupiter.java
create mode 100644 stream-tests/src/test/java/org/apache/pekko/stream/javadsl/SourceWithContextTest.java
create mode 100644 stream-tests/src/test/resources/application.conf
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
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/io/TlsGraphStageEdgeCasesSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/io/TlsGraphStageIsolatedSpec.scala
copy docs/src/test/scala/docs/stream/operators/sourceorflow/FoldWhile.scala => stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/DeflateAutoFlushSpec.scala (64%)
copy docs/src/test/scala/docs/stream/operators/sourceorflow/FoldWhile.scala => stream-tests/src/test/scala/org/apache/pekko/stream/io/compression/GzipAutoFlushSpec.scala (65%)
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/EagerFutureSinkSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowAlsoToSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDoOnCancelSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowDoOnFirstSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowMapAsyncPartitionedSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowOnErrorContinueSpec.scala
create mode 100644 stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/SourceSinkSpec.scala
rename stream/src/main/scala-2.13/org/apache/pekko/stream/javadsl/CollectionUtil.scala => stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/TlsEngineSelectionSpec.scala (54%)
copy actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => stream-typed/src/main/java/org/apache/pekko/stream/typed/javadsl/package-info.java (70%)
rename actor/src/main/scala-2.13+/org/apache/pekko/util/FunctionConverters.scala => stream/src/main/java/org/apache/pekko/stream/javadsl/package-info.java (70%)
copy stream-testkit/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/optimized-mandatory-attributes.excludes (69%)
create mode 100644 stream/src/main/mima-filters/2.0.x.backwards.excludes/pr-2916-boundary-event-allocation.excludes
create mode 100644 stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-dead-actorprocessor.excludes
copy remote/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-materializer-settings.excludes (51%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-fanout-processor.excludes (70%)
copy actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-fanout-publisher-sink.excludes (81%)
copy stream-testkit/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-gunzip.excludes (79%)
rename actor/src/main/mima-filters/1.1.x.backwards.excludes/backoff-calculation.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-internal-unzip.excludes (78%)
copy remote/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes => stream/src/main/mima-filters/2.0.x.backwards.excludes/remove-substream-cancel-strategy.excludes (56%)
delete mode 100644 stream/src/main/scala/org/apache/pekko/stream/StreamRefSettings.scala
delete mode 100644 stream/src/main/scala/org/apache/pekko/stream/SubstreamCancelStrategy.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/TypePreservingFanIn.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/TypePreservingFanOut.scala
delete mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/ExposedPublisherReceive.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/FailedConcat.scala
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
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/FutureConcat.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/IterableConcat.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/JavaStreamConcat.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/RepeatConcat.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/CountSink.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/DoOnCancel.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/DoOnFirst.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/InflightSources.scala
copy stream/src/main/scala/org/apache/pekko/stream/impl/fusing/{IterableSource.scala => IteratorSource.scala} (56%)
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/RangeSource.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/io/TlsEngineHelpers.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/io/TlsGraphStage.scala
create mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/streamref/StreamRefDefaultSettings.scala
delete mode 100644 stream/src/main/scala/org/apache/pekko/stream/impl/streamref/StreamRefSettingsImpl.scala
create mode 100644 testkit/src/test/java/org/apache/pekko/testkit/PekkoJUnitJupiterActorSystemResource.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org