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

104 commits

Author SHA1 Message Date
He-Pin(kerr)
7eef4e017d
chore:Fix up typos for unfoldResource* operators. (#1190) 2024-03-15 02:17:44 +08:00
PJ Fanning
06cff559a4
some doc changes (#1177) 2024-03-09 13:57:01 +01:00
He-Pin(kerr)
c8a99aa590
chore: Remove the deprecation of statefulMapConcat operator. (#1147) 2024-02-29 13:11:11 +08:00
PJ Fanning
1e41829bf7
in TlsActor flush data to user only after handshake has finished (#1128) 
Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
 2024-02-18 10:33:00 +01:00
AndyChen(Jingzhang)
8ce4973fc9
Configuration typo fixes (#1100) 
* configuration typo

* chore: all module configuration typo fix

* apply suggestion
 2024-02-05 17:21:23 +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
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
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