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

96 commits

Author SHA1 Message Date
PJ Fanning
a2a42eab33
fix bug in docs that uses akka names for configs (#1057) 2024-01-28 00:45:47 +08:00
He-Pin(kerr)
db4f57396d
chore: Make use of pattern matching on singleton type instead. (#1026) 
More info: @som-snytt point out in https://scala-lang.org/files/archive/spec/2.13/08-pattern-matching.html#type-patterns see singleton.
 2024-01-27 23:33:06 +08:00
He-Pin(kerr)
4c20580ff2
chore: Add Flow#flattenMerge operator. (#1045) 2024-01-27 18:03:23 +08:00
He-Pin(kerr)
325b463ee1
perf: Add dedicated collectFirst implementation. (#1041) 2024-01-26 14:47:04 +08:00
He-Pin(kerr)
5793433fd3
chore: Add @since 1.1.0 for flatten operator. (#1046) 2024-01-26 10:08:47 +08:00
He-Pin
0c01ab4242 chore: Remove unused attributes in Stages. 2024-01-23 20:43:20 +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)
cd70ae8a6a
perf: Micro optimization for collect* operator. (#983) 2024-01-20 19:31:16 +08:00
He-Pin(kerr)
637d72af7a
chore: Clean up some duplicated code. 
---------

Co-authored-by: Matthew de Detrich <matthew.dedetrich@aiven.io>
 2024-01-20 09:38:13 +01: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
kerr
cf70478201
feat: Add dimap operator to Flow. (#942) 2024-01-15 15:01:34 +08:00
He-Pin
43bab55616 chore: Add @since 1.1.0 to contramap operator. 2024-01-14 23:09:49 +08:00
He-Pin
447728f3c0 feat: Add flatten operator. 2024-01-14 20:24:06 +08:00
Laglangyue
6872f9c8b7
Fix some non-standard comments (#939) 
* Fix some non-standard comments

* revert

---------

Co-authored-by: Jiafu Tang <jiafu.tang@qq.com>
 2024-01-14 12:47:51 +01:00
kerr
72f0a426b8
feat: Add support for for comprehensions. (#935) 2024-01-14 00:39:44 +08:00
He-Pin
3f8be563b9 feat: Make SingleConsumerMultiProducer the default mailbox for stream. 2024-01-11 14:57:09 +08:00
He-Pin
ccce5c0426 feat: Optimize recoverWith stream operator for single source. 2024-01-10 02:57:44 +08:00
PJ Fanning
468aab0c63
reformat some headers (#921) 
* reformat some headers

* add new line at EOF
 2024-01-09 19:14:17 +01:00
kerr
2b3818b55a
feat:Add onErrorComplete stream operator. (#913) 2024-01-08 02:30:52 +08:00
kerr
5cb7ad7d75
feat: Reimplement MapConcat operator without statefulMapConcat. (#902) 
* feat: Reimplement MapConcat operator without statefulMapConcat.

* chore: sort imports

* chore: Remove the @inline annotation
 2024-01-04 13:33:08 +08:00
Matthew de Detrich
f8c4aee8be Remove Scala 3 inline keyword from Java specific conversion methods 2024-01-01 01:55:16 +01:00
Matthew de Detrich
0f1db5301e Fix remaining missing inline statements/annotations 2023-12-30 07:13:27 +01:00
He-Pin
09023ce47a perf: Drop the usages of SupervisedGraphStageLogic to reduce allocation. 2023-12-28 15:56:48 +08:00
Matthew de Detrich
b818925edc Replace SubstreamCancelStrategy with SupervisionDecider for Split 2023-12-28 05:46:37 +01:00
He-Pin
413e79f5d3 chore: Fix GraphApply.scala.template 2023-12-25 12:49:47 +08:00
jxnu-liguobin
417196fb46
Optimize closeState flag (#872) 
Co-authored-by: jxnu-liguobin <jxnu-liguobin@outlook.com>
 2023-12-25 08:30:27 +08:00
He-Pin
16e587ded1 perf: Fold In&OutHanlder in FlatMapPrefix. 2023-12-24 22:15:54 +08:00
He-Pin
6b3096c28a chore: Add special null value handling doc for mapAsync and mapAsyncUnordered. 2023-12-24 16:34:00 +08:00
He-Pin
1ecf66c6ff =str Remove unused comments 2023-12-23 21:11:39 +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
80cd63faf5 =str code clean up in Sliding. 2023-12-23 18:37:45 +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
fecd517d48 =str Fold InHandler and outHandler for UniqueBidiKillSwitchStage. 2023-12-18 16:09:30 +08:00
He-Pin
a159aee6d8 +str Add combine seq method to Source and Sink. 2023-12-18 16:09:00 +08:00
He-Pin
0eed6a128b =str Fold InHandler and OutHandler for operator Scan. 2023-12-18 01:01:30 +08:00
He-Pin
a7a49bd24e =str Fold InHandler and OutHandler for operator ActorRefSource. 2023-12-17 18:32:08 +08:00
kerr
3d9e723e22
=str Fix maybe throw for MinimalStage. (#822) 2023-12-02 17:42:25 +08:00
PJ Fanning
ccce880d4c
license headers for mima files (#813) 2023-11-23 09:41:44 +01:00
He-Pin
1b1f57224b =str Tweak the stream mapAsyncPartitioned operator 2023-10-10 02:34:54 +08:00
He-Pin
cdfcc56e2f =str Make decider a lazy val. 2023-09-27 14:32:15 +08:00
Naoki Yamada
201992d984 Fix invalid scaladoc links which cannot be found (#353) 
* Add enough package name
* Fix invalid syntax of links to a method
 2023-09-26 19:26:45 +08:00
AndyChen
07c5935ddb
chore: javadoc link and typo fixes 2023-09-24 15:00:30 +02: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
9f2a9e657a =str Remove futureCB in MapAsyncUnordered. 2023-09-03 20:10:37 +08:00
He-Pin
194602c849 =str Fold InHandler and OutHandler into GraphStageLogic for recoverWith. 2023-09-03 18:41:29 +08:00
He-Pin
cc7fa75731 =str Use OptionVal in Recover instead of Option. 2023-09-03 18:18:34 +08:00