Commit graph

30 commits

Author SHA1 Message Date
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
He-Pin(kerr)
ec7fdc7d0f
feat: Add groupedAdjacentBy and GroupedAdjacentByWeighted operators. (#1937) 2025-07-10 10:54:46 +08:00
He-Pin(kerr)
e6662e12de
feat: Add dropRepeated stream operator. (#1868) 2025-05-29 06:43:17 +08:00
虎鸣
898b2936e1 feat: Add Sink.none operator 2024-12-28 19:12:21 +08:00
Matthew de Detrich
60c480aecd Add optionalVia and unsafeOptionalDataVia 2024-08-21 14:54:21 +02:00
PJ Fanning
6cdd3e9f49
make SchedKey final (#1365) 2024-06-14 10:02:09 +01:00
He-Pin(kerr)
a9584ec520
feat: Add UntypedAbstractActorWithTimers (#1361) 2024-06-14 16:14:55 +08:00
He-Pin(kerr)
2c3e9b43b6
chore: Add Source.fromArray operator for Java dsl. (#1248) 2024-04-30 22:52:39 +08:00
He-Pin(kerr)
77532c1bb5
feat: Add retry with predicate (#1269) 2024-04-23 20:34:16 +08:00
He-Pin(kerr)
68bd00659e
chore: Add Source.iterate operator. (#1244) 2024-04-03 01:10:19 +08:00
He-Pin(kerr)
55477ac6eb
Add missing java api for StreamTestKit (#1186)
* Add missing java api for StreamTestKit

* polish

* chore: Add more methods to streamKit

---------

Co-authored-by: naosense <pingao777@gmail.com>
2024-03-20 23:31:25 +08:00
Luigi
abad72d869
feat: Add Sink.exists operator (#990)
* feat: +Flow.exists & Sink.exists

* chore: Update some doc and code.

* chore: Update method names in doc.

---------

Co-authored-by: He-Pin <hepin1989@gmail.com>
2024-01-30 14:31:23 +08:00
Laglangyue
f6da401abf
feat: Add Sink#forall operator (#989)
Co-authored-by: Jiafu Tang <jiafu.tang@qq.com>
2024-01-28 17:54:07 +08:00
He-Pin(kerr)
2431eb4083
feat: Add Flow/Sink#foldWhile operator. (#1012) 2024-01-22 19:14:34 +08:00
He-Pin(kerr)
51b7ac519a
feat: Add collectFirst stream operator. (#984) 2024-01-20 19:39:22 +08:00
He-Pin(kerr)
19da73673d
feat: Add collectWhile operator. (#964) 2024-01-17 01:07:47 +08:00
He-Pin(kerr)
bd8ee25b80
feat: Add mapWithResource stream operator. (#931) 2024-01-16 18:29:05 +08:00
He-Pin(kerr)
df302b8ee6
feat: Add create method to PFBuilder. (#947) 2024-01-15 17:37:14 +08:00
kerr
cf70478201
feat: Add dimap operator to Flow. (#942) 2024-01-15 15:01:34 +08:00
He-Pin
d829637ef2 chore: Fix RecipeAdhocSource test. 2023-12-28 17:58:37 +08:00
PJ Fanning
b0fdac259b
adjust ASF header (#450) 2023-06-22 14:19:26 +01:00
Matthew de Detrich
07df607192 Add FunctionConverters, FutureConverters and ObjectConverters 2023-05-08 12:03:37 +02:00
PJ Fanning
5322174ecc replace 2551 with 7354 2023-03-09 05:00:01 +08:00
PJ Fanning
785369030d change default port number to 7355 2023-03-09 05:00:01 +08:00
PJ Fanning
7e653454a9
use pekko: in urls and fix other branding issues (#184)
* use pekko: in urls and fix other branding issues

* update comments

* fix artery test

* test changes

* scalafmt

* try to fix some tests and fixing more akka refs

* more akka refs

* more changes

* more akka refs

* Update LeaseMajoritySpec.scala

* Update docs/src/main/paradox/testing.md

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* Update docs/src/main/paradox/project/migration-guides.md

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* Update actor/src/main/scala/org/apache/pekko/serialization/Serialization.scala

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* Update scripts/release-train-issue-template.md

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* revert link-validation change

* Update JacksonModule.scala

* revert key name changes to fix 2 tests

* fix one test

* more test trouble

* more test issues

* fix hashing test

* Update RouterTest.java

* update code comment

---------

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
2023-02-22 12:48:15 +01:00
Jonas Chapuis
3d93c29737
Renames in doc #98 (#100)
* Rename some base_url values in Paradox.scala
* Rename Akka to Pekko in documentation, also adapt/remove small blocks of text that were no longer consistent or adequate
* Rename Akka to Pekko in some related files outside the doc directory
* Rename akka-bom to pekko-bom
* Rename artifacts prefixes from akka to pekko
* Add links to Apache documents in licenses.md
* Add links to Akka migration guides for earlier versions
2023-01-18 08:13:01 +01:00
He-Pin
4ac0f00a47 Update headers with The Apache header annotated. 2023-01-12 10:59:28 +08:00
Matthew de Detrich
0cb5056ad5 Rename classes containing Akka to Pekko 2022-12-03 11:49:30 +01:00
Greg Methvin
3d93dbcb81
Rename akka to pekko in configuration (#63)
Resolves https://github.com/apache/incubator-pekko/issues/54
2022-12-02 04:53:48 -08:00
PJ Fanning
708da8caec
rename akka-docs dir to docs (#62) 2022-12-02 10:49:40 +01:00