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

62 commits

Author SHA1 Message Date
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
He-Pin
d2d1902ce4 =str Fold InHandler and OutHandler into GraphStageLogic for wiretap. 2023-09-03 18:15:46 +08:00
He-Pin
23b81b2f22 =str Make use of applyOrElse in MapError operator. 2023-09-03 18:10:27 +08:00
PJ Fanning
4bfe071ab9 Having @deprecated and @Deprecated annotations on same function breaks scala3 build 2023-09-03 17:11:34 +08:00
He-Pin
8d2141a5c9 =str Deprecate statefulMapConcat operator. 2023-09-02 00:50:10 +08:00
He-Pin
78644856a2 =str Drop the partial function usage in Flow#zipWithIndex. 2023-09-01 14:46:33 +08:00
kerr
e8a1c3f148 =str Fix CompletionStage#toCompletableFuture may throw UnsupportedOperationException. 2023-08-30 01:55:57 +08:00
He-Pin
a855e58bfc =str Make use of statefulMap to implement zipWithIndex. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-28 18:03:00 +08:00
He-Pin
54e83ca812 =str Resort the OnNext extractor order. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-27 21:38:27 +08:00
He-Pin
5ad70fffeb =str Add IterableSource. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-24 15:22:25 +08:00
Dongxu Wang
95bcbdd139
improve typing in stream/impl/package (#585) 2023-08-22 09:23:02 +01:00
He-Pin
fc26f57c09 =str Mark LazyFutureSource final. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-22 14:11:18 +08:00
Dongxu Wang
580f12c29f
clean GraphAssembly in scaladoc since which has gone for a while (#579) 2023-08-18 00:07:52 +01:00
Dongxu Wang
2aa08651d4
typo in Concat$/scaladoc (#577) 2023-08-16 16:55:29 +01:00
Dongxu Wang
80e4e800c8
improve a/an after get (#566) 2023-08-12 15:59:30 +01: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
He-Pin
f24e3887f3 =str Implement Source.never as a dedicated GraphStage. 2023-08-11 00:36:25 +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
464517a547 =str Make use of Set instead of List to reduce contention. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-06 20:06:15 +08:00
kerr
cb867edb4d !str Logging error instead of failing the keepAlive operator. 2023-08-06 02:58:20 +08:00
He-Pin
5b97885623 +str Add startAfterNrOfConsumers to BroadcastHub. 2023-08-05 16:03:59 +08:00
PJ Fanning
4169e7d476 fix up some docs with version numbers that are Akka versions 2023-08-04 13:03:25 +08:00
kerr
1042dcb0c9 =str Add LazyFutureSource to avoid sub materialization. 2023-08-02 17:08:05 +08:00
kerr
43d4737902 =str Avoid sub materialization in lazySingle. 2023-08-02 11:51:33 +08:00
PJ Fanning
533759ae56
enable mima check (#481) 
* enable mima check

* use java 11 when running mima checks (java 8 builds are missing jfr classes)

* copy over excludes from akka

* fix up excludes
 2023-07-15 10:31:54 +01:00
PJ Fanning
b0fdac259b
adjust ASF header (#450) 2023-06-22 14:19:26 +01:00
PJ Fanning
966204814e
TLSActor: apply check to avoid an endless loop (#443) 
* TLSActor: apply check to avoid an endless loop

* add constant
 2023-06-21 17:51:26 +01:00
PJ Fanning
279d65a7fa
still finding some stray akka refs (#441) 2023-06-21 12:52:59 +01:00
PJ Fanning
01379c4171
Scala3 doc build does not like java @Deprecated mixed with Scala @deprecated (#406) 
* Scala3 doc build does not like java `@Deprecated` mixed with Scala `@deprecated`

* Update ActorSource.scala
 2023-06-16 15:27:11 +01:00
PJ Fanning
1612950702
fix up refs to Akka in source code (#374) 
* fix up refs to Akka in source code

* Update distributed-data.md
 2023-06-07 14:51:57 +01:00
Matthew de Detrich
def5d6e388 Rename akka files and folders to pekko 2023-06-01 19:25:55 +02: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