Commit graph

211 commits

Author SHA1 Message Date
PJ Fanning
a55a719c8e
release notes for 1.2.1 (#2245) 2025-09-24 11:58:14 +01:00
He-Pin(kerr)
a579679445
feat: Add Sink#source (#2250)
* feat: Add Sink#source
2025-09-23 17:10:26 +08:00
He-Pin(kerr)
a1ade992ff
feat: Add Sink#count operator. (#2244)
* feat: Add Sink#count operator.

* Use .asInstanceOf for better performance

---------

Co-authored-by: Matthew de Detrich <mdedetrich@gmail.com>
2025-09-21 16:15:13 +08:00
Ronan Takizawa
57812486e1
fix: drop vavr (#2248) 2025-09-21 01:33:46 +08:00
Ronan Takizawa
1feb26f89e
fix: drop fiddle_code (#2237)
* fix: drop fiddle_code

* fix: fix indentation

* fix: fix formatting

* fix: fix failing pull request test
2025-09-20 09:04:55 +01:00
He-Pin(kerr)
870d4499cc
chore: sort imports (#2235) 2025-09-20 11:30:05 +08:00
He-Pin(kerr)
8254acc0e8
chore: Remove ccompat.JavaConverters (#2234) 2025-09-20 01:12:16 +08:00
PJ Fanning
f2b677dfa0
remove scala 2.12 support (#1986)
* remove scala 2.12 support

* move around some source because we don't need as many source dirs

* move more files

* remove annotations

* remove annotations

* Create remove-scala-2.12-support.excludes

* remove some scala-2.12 refs

* remove compat.PartialFunction

* Update remove-scala-2.12-support.excludes
2025-09-13 10:03:10 +01:00
He-Pin(kerr)
0f6def662f
chore: Make use of japi.funtion.* in Patterns (#2198) 2025-09-13 15:45:20 +08:00
PJ Fanning
f48ec1d425
update docs for calculateDelay (#2196)
* add back BackoffSupervisor.calculateDelay due to bin compat issues (#2195)

* add back BackoffSupervisor.calculateDelay due to bin compat issues

* Update BackoffSupervisor.scala

* Update releases-1.2.md

* Update BackoffSupervisor.scala

* remove deprecated method
2025-09-12 17:32:37 +01:00
He-Pin(kerr)
6f2a65da4c
chore: Make use of japi.function in stream api. (#2143) 2025-09-05 03:24:26 +08:00
PJ Fanning
e3c5fe222c
release notes for 1.2.0 (#2082)
* release notes for 1.2.0

* Update releases-1.2.md

* Update releases-1.2.md

* Update releases-1.2.md
2025-09-01 11:10:31 +01:00
He-Pin(kerr)
b5131ae689
feat: Add Flow/Source#onErrorResume for javadsl. (#2120) 2025-08-31 20:34:34 +08:00
He-Pin(kerr)
f879bbb553
chore: Remove left org.apache.pekko.japi.Function in doc (#2105) 2025-08-30 16:40:46 +08:00
PJ Fanning
497c7c1b6c
use CompletionStage in more Java tests (#2094) 2025-08-26 08:58:30 +01:00
PJ Fanning
5a8e161ec5
use Java CompletionStage instead of Scala Future in pekko-persistence Java APIs (#2092)
* Don't use Scala Futures in Java APIs

Sketching out #1417 - incomplete and notably not bothering
with binary compatibility yet, just to illustrate the idea.

* javafmt

* javafmt

* Update SnapshotStore.scala

* scalaAnyToUnit

* use ExecutionContexts.parasitic

* Update SnapshotStore.scala

* Update LambdaPersistencePluginDocTest.java

* parasitic

* Update LambdaPersistencePluginDocTest.java

* docs

* recovery

* javafmt

* Update LambdaPersistencePluginDocTest.java

---------

Co-authored-by: Arnout Engelen <arnout@bzzt.net>
2025-08-25 23:30:16 +01:00
PJ Fanning
56470a4569
Java Docs: use instanceof with name binding (#2087)
* Java Docs: use instanceof with name binding

* remove changes in generated code

* Update docs/src/test/java/jdocs/ddata/protobuf/TwoPhaseSetSerializer2.java

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* merge issue

---------

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
2025-08-25 13:45:13 +01:00
He-Pin(kerr)
00b0a99278
chore: bump javafmt to 0.10.0 (#2081)
* chore: bump javafmt to 0.10.0

* chore: format with javafmt
2025-08-25 19:32:35 +08:00
He-Pin(kerr)
8e21fd0269
chore: Remove FI (#2078) 2025-08-24 16:51:54 +08:00
He-Pin(kerr)
806d33c90e
chore: Remove OverflowStrategy#dropNew (#2073) 2025-08-24 05:24:43 +08:00
He-Pin(kerr)
afb38c5f17
chore: Remove deprecated methods in Futures (#2070) 2025-08-24 02:17:52 +08:00
He-Pin(kerr)
db92fad13d
feat: Add CompletionStages util. (#2060) 2025-08-23 21:45:30 +08:00
PJ Fanning
e0619c34fb
generate source with protobuf 32 (#2036)
* generate source with protobuf 32

* javafmt
2025-08-20 08:21:18 +01:00
Matthew de Detrich
adc1d669ce feat: Add materializeIntoSource 2025-08-18 14:09:43 +02:00
PJ Fanning
08d3896310
remove old deprecated dns code (#2023)
* remove old deprecated dns code

* remove test that uses old deprecated and now removed code

* Update DnsCompileOnlyDocSpec.scala

* Update remove-deprecated-methods.excludes

* mima

* try to fix docs

* more issues
2025-08-10 08:52:41 +01:00
PJ Fanning
ad1ddf04c9
remove deprecated stream future operators (#2012)
* remove deprecated stream future operators

* Update maybe.md
2025-08-07 09:35:25 +01:00
He-Pin(kerr)
836ae6025e
chore: Remove Java api Option (#2007) 2025-08-05 20:34:45 +08:00
He-Pin(kerr)
08ea94bb4b
chore: Migrate to pekko.japi.function (#2001)
* chore: Remove javaapi.Function

* chore: Remove javaapi.Function2

* chore: Remove javaapi.Procedure

* chore: Remove javaapi.Predicate

* chore: Remove javaapi.Creator

* chore: Remove javaapi.Effect

* chore: Add mima

* Update actor-typed/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update stream/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update persistence/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

* Update actor/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
2025-08-05 10:45:25 +08:00
PJ Fanning
0dd219fab4
remove more deprecated pekko-stream methods (#1996)
* remove deprecated setup methods

* remove deprecated lazyInit methods

* more deprecated methods

* Update SubFlow.scala

* scalafmt

* Update SubFlow.scala

* subflow/subsource

* Update DslFactoriesConsistencySpec.scala

* remove docs for removed operators
2025-08-03 10:55:37 +01:00
PJ Fanning
19788583ee
remove more deprecated code (#1984)
* remove more deprecated code

* Update DslFactoriesConsistencySpec.scala

* mima

* remove docs for removed FileIO operations

* more

* remove foreachparallel

* remove deprecated patterns

* tidy up

* Update remove-deprecated-methods.excludes
2025-08-02 13:18:20 +01:00
PJ Fanning
6a995664ea
move jdk9 source code (#1976)
* move jdk9 source code

* Update Events.scala

* javafmt

* unused import

* remote classes

* Update JFRRemotingFlightRecorder.scala

* stream tests

* javafmt

* doc links

* remove PekkoDependWalker

* build issues

* remove mention of JDK 9

* Update JavaFlowSupport.java
2025-07-31 10:36:49 +01:00
PJ Fanning
ab80e8776e
Release notes for 1.2.0-M2 (#1943)
* init release notes

* more changes

* Update releases-1.2.md

* Update releases-1.2.md

* Create publish-1.2-docs.yml
2025-07-21 10:27:41 +01:00
PJ Fanning
947ee49293
Release notes 1.1.5 (#1931) (#1952)
* pekko 1.1.5: release notes

* fix wrong PR link

merge issues
2025-07-18 09:19:23 +01:00
He-Pin(kerr)
ec7fdc7d0f
feat: Add groupedAdjacentBy and GroupedAdjacentByWeighted operators. (#1937) 2025-07-10 10:54:46 +08:00
PJ Fanning
220981a141
try making TLS v1.3 the default (#1901)
* try making TLS v1.3 the default

* tls 1.3 in docs and some test fixes (new cipher suites)

* remove TLS_CHACHA20_POLY1305_SHA256

* run java 24 tests

* Update RemoteConfigSpec.scala

* Revert "run java 24 tests"

This reverts commit 479408951303e4389b88d288a5ac4aa0d448c4d3.

* test issues

* Update TcpSpec.scala
2025-06-24 10:23:14 +01:00
He-Pin(kerr)
9577b01b10
chore: bump scalafmt to 3.9.7 (#1916) 2025-06-24 10:27:14 +02:00
PJ Fanning
40ea0bc5cf
Update releases-1.1.md (#1883) (#1900) 2025-06-13 15:23:15 +01:00
He-Pin(kerr)
e6662e12de
feat: Add dropRepeated stream operator. (#1868) 2025-05-29 06:43:17 +08:00
PJ Fanning
c44dc07ed8
Issue forming mixed Akka/Pekko cluster when classic remoting with SSL/TLS is used (#1857)
* create test for mixed cluster (classic netty with ssl)

* wip

* truststore/keystore

* Update MixedProtocolClusterSpec.scala

* Update MixedProtocolClusterSpec.scala
2025-05-21 20:58:30 +01:00
He-Pin(kerr)
d286408673
chore: update Scala 3 to 3.3.6 (#1817)
* chore: test with scala 3.3.6

* chore: bump version to 3.3.6-RC3

* chore: bump version to 3.3.6
2025-05-08 00:56:24 +08:00
He-Pin(kerr)
bc4557b0bf
feat: Add takeUntil operator (#1820) 2025-04-20 00:14:32 +08:00
PJ Fanning
05044a65d3
protobuf-java 4.29.3 (#1795)
* try protobuf-java 4.30.0

* regen code

* javafmt

* mima

* Create protoc4-upgrade.excludes

* more mima

* Update protoc4-upgrade.excludes
2025-04-17 23:10:33 +02:00
He-Pin(kerr)
f4c71ea162
chore: Extract switch to method in Switch. (#1804) 2025-03-22 20:40:11 +08:00
Martin Hansen
57af84a56a
feat: Add switchMap operator (#1787)
* feat: switchMap

* chore: minor code review issues

- adjust import style
- adjust header

* chore: fix header check

(add missing newline)

* chore: fix java formatting

* docs: fix operator docs

* docs: improve SwitchMap description

* chore: various review issues

* docs: fix typo

* docs: fix another typo

* chore: more review changes
2025-03-09 04:32:24 +08:00
PJ Fanning
5f64ccbedd
remove incomplete section in cluster-singleton.md (#1788) 2025-03-07 11:07:09 +08:00
PJ Fanning
22685b94c5
mistake in releases-1.2.md (#1774) 2025-02-17 17:35:33 +01:00
PJ Fanning
f3f03cf869
release notes for 1.2.0-M1 (#1756) 2025-02-09 22:56:21 +01:00
scala-steward-asf[bot]
919d9c9309
Update protobuf-java to 3.25.6 (#1748)
* Update protobuf-java to 3.25.6

* regenerate protobuf classes with protoc 25.6

---------

Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
Co-authored-by: Arnout Engelen <arnout@bzzt.net>
2025-01-27 11:26:18 +01:00
He-Pin(kerr)
2469f729f7
feat: Add support for switching scheduler (#1724) 2025-01-23 03:55:15 +08:00
He-Pin(kerr)
189c893531
chore: Add doc about virtual thread executor. (#1737) 2025-01-21 15:52:16 +08:00