PJ Fanning
1c1ca52ae4
move mima files back to 1.1.x ( #1982 )
2025-07-31 11:29:22 +01: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
PJ Fanning
efc50b993e
remove some deprecated code from streams module ( #1958 )
...
* remove some deprecated code from streams module
* Create remove-deprecated-methods.excludes
2025-07-31 08:30:22 +01:00
He-Pin(kerr)
af6b408cfd
=str Make SubFlow and SubSource a final class. ( #619 )
2025-07-31 14:30:43 +08: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)
0199e84444
chore: Make calculateDelay a public method. ( #1940 )
...
* chore: Make calculateDelay a public method.
* Update backoff-calculation.excludes
* move file
---------
Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
2025-07-12 21:34:08 +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
He-Pin(kerr)
9577b01b10
chore: bump scalafmt to 3.9.7 ( #1916 )
2025-06-24 10:27:14 +02:00
He-Pin(kerr)
3050c2af73
chore: Set vector builder to null after stage completed to avoid leak. ( #1917 )
2025-06-23 10:54:47 +08: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)
572bebd619
fix: Fix wrong name attribute for iterate and mapAsyncPartitionUnordered operators. ( #1869 )
2025-05-29 10:16:54 +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
Matthew de Detrich
b865cf11e0
chore: Add since for newly added methods
2025-05-02 17:23:51 +02: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
PJ Fanning
05044a65d3
protobuf-java 4.29.3 ( #1795 )
...
* try protobuf-java 4.30.0
* regen code
* javafmt
* mima
* Create protoc4-upgrade.excludes
* more mima
* Update protoc4-upgrade.excludes
2025-04-17 23:10:33 +02:00
He-Pin(kerr)
f4c71ea162
chore: Extract switch to method in Switch. ( #1804 )
2025-03-22 20:40:11 +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
scala-steward-asf[bot]
919d9c9309
Update protobuf-java to 3.25.6 ( #1748 )
...
* Update protobuf-java to 3.25.6
* regenerate protobuf classes with protoc 25.6
---------
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-27 11:26:18 +01: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)
b160861c41
chore: Require parallelism >= 1 in MapAsync and MapAsyncUnordered ( #1700 )
2025-01-10 21:18:39 +08:00
He-Pin(kerr)
18e98d4e38
chore: Require breadth >= 1 in FlattenMerge ( #1699 )
2025-01-10 19:16:01 +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)
c953f50ded
chore: Avoid forwarding method on ArrayDequeue in stream module. ( #1687 )
2025-01-06 10:45:35 +08:00
He-Pin(kerr)
7782cf55e8
chore: Use more lambda instread in stream module. ( #1686 )
2025-01-06 10:10:51 +08:00
He-Pin(kerr)
477fd393c2
fix: Fix occasional ordering issue in FlowWithContext#unsafeOptionalDataVia ( #1681 )
...
* chore: Test more rounds for unsafeDataVia keeping order.
* fix: Fix flask ordering in FlowWithContext#unsafeOptionalDataVia operator.
2025-01-06 00:10:18 +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)
ce3620fc1a
chore: Fix leak in FlatMapPrefix operator. ( #1622 )
2025-01-04 00:56:50 +08:00
He-Pin(kerr)
d34927b56b
fix: Fix a leak in PrefixAndTail operator. ( #1623 )
2025-01-03 21:46:40 +08:00
He-Pin(kerr)
7fef5b75f3
fix: avoid call finalizeStage more times than once. ( #1650 )
2024-12-31 20:17:07 +08:00
He-Pin(kerr)
9596ea4c18
perf: Reduce loops in when clean queue in BroadcastHub ( #1628 )
2024-12-30 13:05:01 +08:00
He-Pin(kerr)
5334ea40f6
chore: Fix the @since of Sink.none operator, should be 1.2.0 ( #1632 )
2024-12-28 21:07:03 +08:00
虎鸣
898b2936e1
feat: Add Sink.none operator
2024-12-28 19:12:21 +08:00
虎鸣
2b916125f0
chore: avoid create an empty array everytime.
2024-12-28 19:10:46 +08:00
He-Pin(kerr)
8bb6e22853
chore: Remove SupervisedGraphStageLogic ( #1619 )
2024-12-22 21:15:45 +08:00
He-Pin(kerr)
65fc751265
chore: fix some IDEA hints. ( #1617 )
2024-12-22 20:43:53 +08:00
He-Pin(kerr)
7184dadf4a
chore: Fix flaky test in unsafeOptionalDataVia ( #1611 )
2024-12-18 10:43:23 +08:00
PJ Fanning
bbbcaccd2c
revert zipWithIndex changes ( #1526 )
...
* revert zipWithIndex changes
* scalafmt
* Update FlowZipWithIndexSpec.scala
2024-10-14 09:28:14 +01:00
Matthew de Detrich
bc32e04b13
Fix CollectionUtil toSeq methods
...
Signed-off-by: Matthew de Detrich <mdedetrich@gmail.com>
2024-10-01 15:17:53 +02:00
PJ Fanning
090390a4f0
issue with full list copies in pekko-stream javadsl ( #1491 )
...
* commit
CollectionUtil
scalafmt
* build issue
* inline
* scala 3 compile issue
* continue use if Util.immutableSeq in Scala 2.12
* Update CollectionUtil.scala
2024-09-30 20:27:45 +01:00
