raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
27351 commits 1 branch 31 tags 268 MiB
Commit graph

40 commits

Author SHA1 Message Date
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)
c818001180
chore: Fix scala constructor finding tests for scala 3. (#1220) 
* chore: Fix scala constructor finding tests for scala 3.

* reorder imports
 2024-03-24 00:27:25 +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
He-Pin
daf84d7870 chore: Fix ActorDocSpec on Scala 3.3 2024-01-30 17:34:11 +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
He-Pin
1e64e31d25 chore: Fix up ForAll comping in nightly build. 2024-01-29 14:29:58 +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)
a2b5b5df22
chore: Run JDK9Test compiling to validate syntax. (#1050) 
* chore: Check java9+ classes in paradox.

* Update .github/workflows/generate-doc-check.yml

Co-authored-by: AndyChen <chinatc@outlook.com>

---------

Co-authored-by: AndyChen <chinatc@outlook.com>
 2024-01-27 22:14:35 +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
kerr
057fe066e8
chore: Fix compiling error in AsSubscriber.java and FromPublisher.java (#953) 2024-01-15 11:12:25 +08:00
PJ Fanning
6883d15576
use StandardCharsets (#934) 2024-01-13 12:40:16 +01:00
He-Pin
d829637ef2 chore: Fix RecipeAdhocSource test. 2023-12-28 17:58:37 +08:00
He-Pin
8d2141a5c9 =str Deprecate statefulMapConcat operator. 2023-09-02 00:50:10 +08:00
He-Pin
bd3270cd3e +str Add Flow contramap. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-11 17:27:50 +08:00
PJ Fanning
b0fdac259b
adjust ASF header (#450) 2023-06-22 14:19:26 +01:00
He-Pin
008bdd5190 =sbt Upgrade to Scala 2.12.18 and 2.13.11. 2023-06-03 21:38:07 +08:00
Matthew de Detrich
480f516398
Unwrap single string interpolation syntax 2023-05-24 16:28:02 +02: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
1969f7580d change 2552+ port numbers 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
0a8b8a572f
set license headers on conf files (#227) 2023-03-03 13:24:19 +01: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
Johannes Rudolph
982780b043
fix compilation of jdk9 docs tests (#177) 2023-02-13 12:21:13 +01:00
PJ Fanning
8338bfed8b
diffs when running scalafmtAll (#155) 2023-02-09 14:38:45 +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