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

107 commits

Author SHA1 Message Date
PJ Fanning
f2b677dfa0
remove scala 2.12 support (#1986) 
* remove scala 2.12 support

* move around some source because we don't need as many source dirs

* move more files

* remove annotations

* remove annotations

* Create remove-scala-2.12-support.excludes

* remove some scala-2.12 refs

* remove compat.PartialFunction

* Update remove-scala-2.12-support.excludes
 2025-09-13 10:03:10 +01:00
He-Pin(kerr)
a0f807d05a
chore: Drop ActorMaterializer class. (#2137) 2025-09-04 04:55:07 +08:00
PJ Fanning
18545a6737
remove ssl-config dependency (#2127) 
* remove ssl-config dependency

* update internal code that doesn't need ActorSystem any more

* scalafmt
 2025-09-02 20:04:39 +01:00
He-Pin(kerr)
b5131ae689
feat: Add Flow/Source#onErrorResume for javadsl. (#2120) 2025-08-31 20:34:34 +08:00
He-Pin(kerr)
00b0a99278
chore: bump javafmt to 0.10.0 (#2081) 
* chore: bump javafmt to 0.10.0

* chore: format with javafmt
 2025-08-25 19:32:35 +08:00
He-Pin(kerr)
806d33c90e
chore: Remove OverflowStrategy#dropNew (#2073) 2025-08-24 05:24:43 +08:00
Matthew de Detrich
adc1d669ce feat: Add materializeIntoSource 2025-08-18 14:09:43 +02:00
PJ Fanning
08d3896310
remove old deprecated dns code (#2023) 
* remove old deprecated dns code

* remove test that uses old deprecated and now removed code

* Update DnsCompileOnlyDocSpec.scala

* Update remove-deprecated-methods.excludes

* mima

* try to fix docs

* more issues
 2025-08-10 08:52:41 +01:00
PJ Fanning
ad1ddf04c9
remove deprecated stream future operators (#2012) 
* remove deprecated stream future operators

* Update maybe.md
 2025-08-07 09:35:25 +01:00
PJ Fanning
1b8de23911
remove deprecated stream converters (#2006) 
* remove deprecated stream converters

* Update StreamConverters.scala

* Update remove-deprecated-methods.excludes

* Update DslFactoriesConsistencySpec.scala
 2025-08-05 15:21:35 +01:00
PJ Fanning
2ff7868281
don't test SessionRenegotiationFirstOne on java 24 (#2003) 2025-08-04 10:05:38 +01:00
PJ Fanning
0dd219fab4
remove more deprecated pekko-stream methods (#1996) 
* remove deprecated setup methods

* remove deprecated lazyInit methods

* more deprecated methods

* Update SubFlow.scala

* scalafmt

* Update SubFlow.scala

* subflow/subsource

* Update DslFactoriesConsistencySpec.scala

* remove docs for removed operators
 2025-08-03 10:55:37 +01:00
PJ Fanning
19788583ee
remove more deprecated code (#1984) 
* remove more deprecated code

* Update DslFactoriesConsistencySpec.scala

* mima

* remove docs for removed FileIO operations

* more

* remove foreachparallel

* remove deprecated patterns

* tidy up

* Update remove-deprecated-methods.excludes
 2025-08-02 13:18:20 +01:00
He-Pin(kerr)
e0f6a88435
=str Switch the type parameter order of UnfoldResourceSource. (#615) 2025-08-02 17:30:06 +08:00
PJ Fanning
6a995664ea
move jdk9 source code (#1976) 
* move jdk9 source code

* Update Events.scala

* javafmt

* unused import

* remote classes

* Update JFRRemotingFlightRecorder.scala

* stream tests

* javafmt

* doc links

* remove PekkoDependWalker

* build issues

* remove mention of JDK 9

* Update JavaFlowSupport.java
 2025-07-31 10:36:49 +01:00
Piotr Sowiński
6ef6ae1446
Allow overriding dispatcher in mapWithResource (#1949) 
* Allow overriding the dispatcher in mapWithResource

Closes #1948
 2025-07-15 12:21:24 +08:00
He-Pin(kerr)
ec7fdc7d0f
feat: Add groupedAdjacentBy and GroupedAdjacentByWeighted operators. (#1937) 2025-07-10 10:54:46 +08:00
He-Pin(kerr)
60a84ce2e2
feat: Add Source#create method (#1823) 2025-07-07 11:06:46 +08:00
PJ Fanning
220981a141
try making TLS v1.3 the default (#1901) 
* try making TLS v1.3 the default

* tls 1.3 in docs and some test fixes (new cipher suites)

* remove TLS_CHACHA20_POLY1305_SHA256

* run java 24 tests

* Update RemoteConfigSpec.scala

* Revert "run java 24 tests"

This reverts commit 479408951303e4389b88d288a5ac4aa0d448c4d3.

* test issues

* Update TcpSpec.scala
 2025-06-24 10:23:14 +01:00
He-Pin(kerr)
9577b01b10
chore: bump scalafmt to 3.9.7 (#1916) 2025-06-24 10:27:14 +02:00
Andreas Lochbihler
de12867f94
Avoid register/unregister race condition that can wipe elements from BroadcastHub (#1841) 
* add test case to demonstrate that BroadcastHub drops elements

* fix the race condition with unregister (refs https://github.com/apache/pekko/issues/1836)

* address review comment: documentation and separate constructor instead of default arguments

* address review comments

* Update Hub.scala

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
 2025-06-02 12:13:50 +01:00
He-Pin(kerr)
197fb6e60e
fix: Change aggregateWithBoundary operator in javadsl to use Optional. (#1876) 2025-05-30 03:20:51 +08:00
He-Pin(kerr)
e6662e12de
feat: Add dropRepeated stream operator. (#1868) 2025-05-29 06:43:17 +08:00
He-Pin(kerr)
980430a399
feat: Add onComplete support for statefulMapConcat operator. (#1870) 
* feat: Add onComplete support for statefulMapConcat operator.

* Update stream/src/main/scala/org/apache/pekko/stream/scaladsl/StatefulMapConcatAccumulator.scala

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>

* Update stream/src/main/scala/org/apache/pekko/stream/javadsl/StatefulMapConcatAccumulator.scala

---------

Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
 2025-05-28 01:11:45 +08:00
He-Pin(kerr)
b0049e695d
feat: Add invokeWithFeedbackCompletionStage for javadsl. (#1819) 
* feat: Add invokeWithFeedbackCompletionStage for javadsl.

* Update stream/src/main/scala/org/apache/pekko/stream/stage/GraphStage.scala
 2025-04-22 22:08:01 +08:00
He-Pin(kerr)
bc4557b0bf
feat: Add takeUntil operator (#1820) 2025-04-20 00:14:32 +08:00
He-Pin(kerr)
8ff1d82717
feat: Add flatMapConcat with parallelism support. (#1702) 2025-03-13 05:11:18 +08:00
Martin Hansen
57af84a56a
feat: Add switchMap operator (#1787) 
* feat: switchMap

* chore: minor code review issues

- adjust import style
- adjust header

* chore: fix header check

(add missing newline)

* chore: fix java formatting

* docs: fix operator docs

* docs: improve SwitchMap description

* chore: various review issues

* docs: fix typo

* docs: fix another typo

* chore: more review changes
 2025-03-09 04:32:24 +08:00
He-Pin(kerr)
ba05791fa0
chore: Handle NormalShutdownReason in MergeHub (#1741) 2025-03-03 19:52:32 +08:00
He-Pin(kerr)
2d5c50c38f
chore: optmize recoverWith to avoid some materialization (#1775) 2025-02-28 20:19:33 +08:00
He-Pin(kerr)
abc18a5cea
feat: Add emitMulti with Spliterator support (#1776) 2025-02-27 21:34:58 +08:00
He-Pin(kerr)
fc45e50b4e
feat: Add TraversalBuilder.getValuePresentedSource method for further optimization. (#1701) 2025-02-17 10:30:02 +08:00
He-Pin(kerr)
4252382d08
chore: Tweak withAttribuets in Flow (#1658) 2025-02-16 14:27:51 +08:00
He-Pin(kerr)
ba639f68a2
chore: Add the missing EmptySource case to TraversalBuilder (#1743) 2025-01-25 06:42:25 +08:00
scala-steward-asf[bot]
5b2aab6f7a
Update scalafmt-core to 3.8.4 (#1717) 
* Update scalafmt-core to 3.8.4

* Reformat with scalafmt 3.8.4

Executed command: scalafmt --non-interactive

* Add 'Reformat with scalafmt 3.8.4' to .git-blame-ignore-revs

* remove postfixOps imports

Assuming we want to keep the default
`rewrite.avoidInfix.excludePostfix = false` - otherwise
we can drop this commit

---------

Co-authored-by: scala-steward-asf[bot] <147768647+scala-steward-asf[bot]@users.noreply.github.com>
Co-authored-by: Arnout Engelen <arnout@bzzt.net>
 2025-01-18 10:36:38 +08:00
He-Pin(kerr)
640a9e9393
fix: avoid boxing in zipWithIndex and fix type signature in SubSource#zipWithIndex (#1669) 2025-01-07 21:18:45 +08:00
He-Pin(kerr)
8f6f97aa2d
chore: Add identity function. (#1671) 2025-01-07 01:00:38 +08:00
He-Pin(kerr)
2ee37454cb
chore: Test more rounds for unsafeDataVia keeping order. (#1680) 2025-01-06 00:06:49 +08:00
He-Pin(kerr)
c8ac6c06b1
chore: Make flatMapPrefix javadsl using java.util.List (#271) 2025-01-04 23:14:09 +08:00
He-Pin(kerr)
def84bf0c1
chore: fix failed in StreamConvertersSpec (#1655) 2024-12-31 21:33:21 +08:00
He-Pin(kerr)
7fef5b75f3
fix: avoid call finalizeStage more times than once. (#1650) 2024-12-31 20:17:07 +08:00
虎鸣
898b2936e1 feat: Add Sink.none operator 2024-12-28 19:12:21 +08:00
PJ Fanning
bbbcaccd2c
revert zipWithIndex changes (#1526) 
* revert zipWithIndex changes

* scalafmt

* Update FlowZipWithIndexSpec.scala
 2024-10-14 09:28:14 +01:00
João Costa
6ceb59ba26
Support primitives in Flow#collectType (#1490) 2024-09-20 21:05:18 +01:00
Matthew de Detrich
f548ea55ad Add wiretap/wiretapContext to FlowWithContext/SourceWithContext 2024-08-27 11:44:08 +02:00
Matthew de Detrich
302f38f148 Add alsoTo/alsoToContext to FlowWithContext/SourceWithContext 2024-08-23 15:56:48 +02:00
Matthew de Detrich
60c480aecd Add optionalVia and unsafeOptionalDataVia 2024-08-21 14:54:21 +02:00
He-Pin(kerr)
1d87923667
feat: Add isCompleted method to BoundedSourceQueue (#1374) 2024-06-18 19:19:02 +08:00
scala-steward-asf[bot]
fa1351b213 Reformat with scalafmt 3.8.2 
Executed command: scalafmt --non-interactive
 2024-06-16 07:56:40 +01:00
He-Pin(kerr)
2c3e9b43b6
chore: Add Source.fromArray operator for Java dsl. (#1248) 2024-04-30 22:52:39 +08:00