Commit graph

50 commits

Author SHA1 Message Date
injae kim
7de1fb2edb
feat: Add AutoCloseable shortcut on mapWithResource (#1053)
* feat: Add AutoCloseable shortcut on mapWithResource

* Enhance test to check resource is closed after stream is completed

* Enhance comment

* Update doc

* Address comment

* Add resume, restart, stop strategy test

* Address comment

* Fix doc

* Fix typo
2024-02-01 18:47:57 +08:00
He-Pin(kerr)
5e00e6b8b7
chore: Remove more reflectiveCall. (#1084) 2024-01-30 23:51:30 +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)
4c20580ff2
chore: Add Flow#flattenMerge operator. (#1045) 2024-01-27 18:03:23 +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)
b1ec854b8c
chore: Fix FlowCollectWhileSpec. #985 2024-01-20 05:01:57 +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
c44c0b7cbd chore: Sort imports on stream,stream-tests,stream-testkit 2024-01-16 16:10:53 +08:00
He-Pin(kerr)
d313eef0a9
chore: Add collect operator test for stream javadsl. (#963) 2024-01-16 10:13:29 +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
PJ Fanning
8c688dad2e
use more of StandardCharsets (#952)
* use more of StandardCharsets

* scalafmt
2024-01-14 23:50:50 +01:00
He-Pin
447728f3c0 feat: Add flatten operator. 2024-01-14 20:24:06 +08:00
kerr
72f0a426b8
feat: Add support for for comprehensions. (#935) 2024-01-14 00:39:44 +08:00
He-Pin
ccce5c0426 feat: Optimize recoverWith stream operator for single source. 2024-01-10 02:57:44 +08:00
kerr
2b3818b55a
feat:Add onErrorComplete stream operator. (#913) 2024-01-08 02:30:52 +08:00
Matthew de Detrich
b818925edc Replace SubstreamCancelStrategy with SupervisionDecider for Split 2023-12-28 05:46:37 +01:00
He-Pin
c78e2d7610 chore: Add tests for not invoking onComplete twice for statefulMap operator. 2023-12-25 19:02:12 +08:00
He-Pin
781b1226e7 =str Optimize concat for javadsl.Source.empty. 2023-12-23 19:38:23 +08:00
He-Pin
873868c87b =str Add dedicated stream timeout exceptions for stream timeout operators. 2023-12-23 19:06:30 +08:00
He-Pin
3a1d31e841 =str Avoid subMaterialization when the provided recover source is empty. 2023-12-23 18:27:46 +08:00
He-Pin
a159aee6d8 +str Add combine seq method to Source and Sink. 2023-12-18 16:09:00 +08:00
kerr
3d9e723e22
=str Fix maybe throw for MinimalStage. (#822) 2023-12-02 17:42:25 +08:00
PJ Fanning
7bee80e058
mapAsyncPartitioned / mapAsyncPartitionedUnordered (#561)
* Create MapAsyncPartition.scala

add license

add test

Update LICENSE

try to fix test

* Update MapAsyncPartitionSpec.scala

wip

Update MapAsyncPartition.scala

wip

* changes to get code to compile with scala 2.12

* more tests

scalafmt

* Update MapAsyncPartition.scala

* make code more closely match the Akka API

java

Update Flow.scala

more java api

* Add ordered version of the operator

* Fix formatting

* update docs

* test null function result

* java api

* add back code to get scala 2.12 compile working again

* Unify mapAsyncPartitioned implementations

* remove special license

Update CopyrightHeader.scala

* java tests

javafmt

* update docs

update tests

update javadoc

---------

Co-authored-by: Jacek Sokol <jacek@scalabs.pl>
2023-09-21 18:35:39 +01:00
He-Pin
e784cd7c99 =test Add BeenCalledTimesGate in tests to make sure some method should only be called specified times. 2023-09-11 10:23:24 +08:00
He-Pin
8d2141a5c9 =str Deprecate statefulMapConcat operator. 2023-09-02 00:50:10 +08:00
He-Pin
3860038d67 =str Makes use of the statefulMap to make code simpler. 2023-08-31 23:28:01 +08:00
He-Pin
5ad70fffeb =str Add IterableSource.
Signed-off-by: He-Pin <hepin1989@gmail.com>
2023-08-24 15:22:25 +08:00
He-Pin
8bb19b39bf =str Skip parsing when buffer size <= 0. 2023-08-12 04:45:18 +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
kerr
eeaec22bd5 !str Eagerly fails flow if the future is already failed. 2023-08-11 17:27:10 +08:00
PJ Fanning
4f570ea24c
Yet more Akka version numbers in deprecation warnings (#545)
* Yet more Akka version numbers in deprecation warnings

more

* more akka version numbers

Update ClusterMessageSerializer.scala

more changes
2023-08-07 00:47:04 +01:00
He-Pin
5b97885623 +str Add startAfterNrOfConsumers to BroadcastHub. 2023-08-05 16:03:59 +08:00
PJ Fanning
b0fdac259b
adjust ASF header (#450) 2023-06-22 14:19:26 +01:00
PJ Fanning
279d65a7fa
still finding some stray akka refs (#441) 2023-06-21 12:52:59 +01:00
Johannes Rudolph
6b90b20334
stream: fix regression in JsonFraming (#44)
* stream: fix regression in JsonFraming

Was introduced in 6b30134c5c where
an invariant was changed what `pos` can be when the loop is run.

* fix when maximumObjectLength is near Int.MaxValue
2023-05-29 16:27:37 +01: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
Sam Byng
46b02c6640
Issue 203: Update the truststore/keystore for stream-tests (#301)
* Update the stream-tests truststore/keystore to refer to pekko-remote

The same truststore/keyspace as the one generate with the Makefile at remote/src/test/resources is used here"

* Revert "Update the stream-tests truststore/keystore to refer to pekko-remote"

This reverts commit 7bab689bb6257e80d2bd8cdff2b8a715bb08c619.

* Issue 203: Update keystore/truststore for stream-tests:

Note that no SAN extension file is used in this case. Therefore the verify hostname code looks at the CN= instead of the subjectAltName field.
I've added a Makefile here to make it easier to regenerate this in future: just delete the trust/keystores and run 'make'

* 203: Add comment explaining new Makefile
2023-04-28 19:29:38 +02:00
PJ Fanning
321c572114
upgrade to jackson 2.14.2 (#273)
* upgrade to jackson 2.14.2

* scala 3.2.2 needed

* another deprecation issue

* ignore deprecation warnings in Scala 3 build

* Update PekkoDisciplinePlugin.scala

* scala 3.2 compile issues

* more scala upgrade issues

* import order

* Update actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/InteractionPatternsSpec.scala

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

---------

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
2023-04-05 15:44:58 +02: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
PJ Fanning
c32fcf1f0a
update more akka refs to use pekko name (#200) 2023-02-17 10:49:40 +01:00
PJ Fanning
8338bfed8b
diffs when running scalafmtAll (#155) 2023-02-09 14:38:45 +01:00
PJ Fanning
474ed8b4d0
use Apache Pekko name for version check (#119) 2023-01-23 12:09:03 +01:00
He-Pin
4ac0f00a47 Update headers with The Apache header annotated. 2023-01-12 10:59:28 +08:00
Matthew de Detrich
24c03cde19
Rename sbt akka modules
Co-authored-by: Sean Glover <sean@seanglover.com>
2023-01-05 11:10:50 +01:00