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

26876 commits

This branch
This branch
All branches
Author SHA1 Message Date
AndyChen
07c5935ddb
chore: javadoc link and typo fixes 2023-09-24 15:00:30 +02:00
Naoki Yamada
b7a5f673a9
add external javadoc links (#353) (#674) 
Co-authored-by: Naoki Yamada <yamada.naoki@tis.co.jp>
 2023-09-23 19:08:15 +01:00
He-Pin
57401818bc =remote Make use of FlushConsolidationHandler to improve throughput. 2023-09-22 02:23:01 +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
e94e7b971b =test Skip ForkJoinPoolStarvationSpec on JDK 21. 2023-09-20 23:57:26 +08:00
He-Pin
2b0f149eb7 =build Use zulu in nightly build to test jdk21. 2023-09-20 18:09:50 +08:00
He-Pin
94ade5d2ea +build Add Jdk 21 to nightly build. 2023-09-20 17:23:06 +08:00
He-Pin
9288d4c6f1 =remote Drop the blocking usage. 2023-09-19 00:00:54 +08:00
He-Pin
62bf7cbc7d =remote Make ues of Netty's default resolver. 2023-09-18 23:08:08 +08:00
He-Pin
efaa82c966 =sbt update scalafmt to 3.7.14 2023-09-18 17:50:40 +08:00
Norbert Tusiński
45488f537b Removing unused import 2023-09-17 14:57:50 +08:00
He-Pin
ee8b99294a =test Fix ssl relative tests on Windows. 2023-09-16 04:10:10 +08:00
kerr
46edc51a82
Migrate the classic transport to Netty 4 without CVEs (#643) 
* !remoting Update classic transport from Netty 3 to netty4

* use lambda

* =sbt Update Netty4 version to 4.1.97.final

* Reduce allocation in ChannelLocalActor.

* Remove the duplicated code in NettyHelpers.
 2023-09-16 02:24:28 +08:00
Matthew de Detrich
d0b9c43bb5 Update to SBT 1.9.6 and use Apache Staging repo constant 2023-09-15 19:50:46 +02: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
b37b5cde89 =test Fix keystore loading on Windows in RemotingSpec. 2023-09-09 22:56:11 +08:00
He-Pin
d0099a1b5c =remote Clean up unused field. 2023-09-09 19:12:21 +08:00
PJ Fanning
e9ab2cc486 agrona 1.19.2 2023-09-09 13:43:50 +08:00
PJ Fanning
7426c8a1f4
simplify some NettyTransport code (#639) 
fix imports

scalafmt
 2023-09-09 00:30:31 +01:00
PJ Fanning
442f54f6fe
link validation job fails (#640) 2023-09-08 23:32:23 +01:00
kerr
68dd099bd0 =sbt Update Scala to 2.13.12 2023-09-08 19:05:02 +08:00
PJ Fanning
4d37f98e76
protobuf-java 3.19.6 (#636) 
Update pekko-protobuf-v3-jar-license.txt
 2023-09-08 11:54:30 +01:00
PJ Fanning
8d34f8039f
scala 3.3.1 (#632) 
* scala 3.3.1

* Update Player.scala

---------

Co-authored-by: kerr <hepin1989@gmail.com>
 2023-09-08 14:19:03 +08:00
He-Pin
299484d9f8 =test Switch pattern matching cases in Player. 2023-09-07 00:08:00 +08:00
Matthew de Detrich
131e774829 Use fetch tags from latest checkout action 2023-09-05 15:25:19 +02: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
Sam Byng
d51b7b30de
GH Workflows: Separate validateCompile step from validatePullRequest: (#300) 
This will make the source of errors in steps clearer, without adding any extra pipeline time.

steps in github jobs are dependent on one another, so the build files can be passed onto prValidation without the need for PR validation to compile again
 2023-09-03 10:45:40 +01: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
He-Pin
3860038d67 =str Makes use of the statefulMap to make code simpler. 2023-08-31 23:28:01 +08:00
kerr
e8a1c3f148 =str Fix CompletionStage#toCompletableFuture may throw UnsupportedOperationException. 2023-08-30 01:55:57 +08:00
PJ Fanning
99cc4e794d
use sbt paradox release (#597) 2023-08-29 14:55:36 +01:00
He-Pin
cbdc8d866c =act Extract AtomicCancellable in Scheduler. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-29 15:06:31 +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
kerr
e6ebc66db8 =sbt Bump sbt to 1.9.4 2023-08-25 18:43:48 +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
3775a18c2e
update ActorSystemSpec to use property based testing for its name (#575) 2023-08-17 09:17:57 +01:00
Dongxu Wang
2aa08651d4
typo in Concat$/scaladoc (#577) 2023-08-16 16:55:29 +01:00
Dongxu Wang
d610a080c5
improve scaladoc for DoNotInherit (#565) 2023-08-15 17:21:53 +01:00
Matthew de Detrich
1542078d29 Rename verifyCodeStyle to checkCodeStyle 2023-08-15 19:15:42 +08:00
He-Pin
c63eae1ab9 =test Fix typo in Player class. 
Signed-off-by: He-Pin <hepin1989@gmail.com>
 2023-08-15 19:13:27 +08:00