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

58 commits

Author SHA1 Message Date
He-Pin(kerr)
2c3e9b43b6
chore: Add Source.fromArray operator for Java dsl. (#1248) 2024-04-30 22:52:39 +08:00
He-Pin(kerr)
68bd00659e
chore: Add Source.iterate operator. (#1244) 2024-04-03 01:10:19 +08:00
injae kim
9e54e4695b
Fix mustBeAbleToUseMapWithAutoCloseableResource broken test (#1241) 
Closes #1229.
 2024-03-30 13:20:31 +01:00
He-Pin(kerr)
c55837e2a8
chore: Add missing create method to javadsl Graph (#1230) 2024-03-24 19:57:42 +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(kerr)
b4ff0fcabf
chore: Pull instead of throw exception in groupBy operator. (#1210) 
When a sub stream is already closed, but the main stream is still continue, instead of throw a TooManySubStreamOpenException, just drop the current element and continue pulling.
 2024-03-20 11:48:39 +08:00
Matthew de Detrich
689e30bbe9 Fix uncaught decider exception in Split with Supervision.resumingDecider 2024-03-19 16:41:51 +01:00
PJ Fanning
06cff559a4
some doc changes (#1177) 2024-03-09 13:57:01 +01:00
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