Commit graph

24 commits

Author SHA1 Message Date
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
PJ Fanning
321c572114
upgrade to jackson 2.14.2 (#273)
* upgrade to jackson 2.14.2

* scala 3.2.2 needed

* another deprecation issue

* ignore deprecation warnings in Scala 3 build

* Update PekkoDisciplinePlugin.scala

* scala 3.2 compile issues

* more scala upgrade issues

* import order

* Update actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/InteractionPatternsSpec.scala

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

---------

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
2023-04-05 15:44:58 +02:00
PJ Fanning
0a8b8a572f
set license headers on conf files (#227) 2023-03-03 13:24:19 +01:00
PJ Fanning
7e653454a9
use pekko: in urls and fix other branding issues (#184)
* use pekko: in urls and fix other branding issues

* update comments

* fix artery test

* test changes

* scalafmt

* try to fix some tests and fixing more akka refs

* more akka refs

* more changes

* more akka refs

* Update LeaseMajoritySpec.scala

* Update docs/src/main/paradox/testing.md

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* Update docs/src/main/paradox/project/migration-guides.md

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* Update actor/src/main/scala/org/apache/pekko/serialization/Serialization.scala

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* Update scripts/release-train-issue-template.md

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>

* revert link-validation change

* Update JacksonModule.scala

* revert key name changes to fix 2 tests

* fix one test

* more test trouble

* more test issues

* fix hashing test

* Update RouterTest.java

* update code comment

---------

Co-authored-by: Johannes Rudolph <johannes.rudolph@gmail.com>
2023-02-22 12:48:15 +01:00
PJ Fanning
c32fcf1f0a
update more akka refs to use pekko name (#200) 2023-02-17 10:49:40 +01:00
PJ Fanning
8338bfed8b
diffs when running scalafmtAll (#155) 2023-02-09 14:38:45 +01:00
PJ Fanning
474ed8b4d0
use Apache Pekko name for version check (#119) 2023-01-23 12:09:03 +01:00
He-Pin
4ac0f00a47 Update headers with The Apache header annotated. 2023-01-12 10:59:28 +08:00
Matthew de Detrich
24c03cde19
Rename sbt akka modules
Co-authored-by: Sean Glover <sean@seanglover.com>
2023-01-05 11:10:50 +01:00