He-Pin(kerr)
3cfe37f016
chore: Use array list for better performance in BroadcastHub ( #2262 )
...
* chore: Use array list for better performance in BroadcastHub
* chore: add benchmark
2025-09-25 08:50:27 +08:00
He-Pin(kerr)
a579679445
feat: Add Sink#source ( #2250 )
...
* feat: Add Sink#source
2025-09-23 17:10:26 +08:00
He-Pin(kerr)
750bf235f1
chore: Fuse in and out handler for setupStage ( #2259 )
2025-09-22 17:16:02 +08:00
PJ Fanning
92ca0314c0
silence compiler warnings new in scala 2.13.17 ( #2255 )
...
* silence compiler warning new in scala 2.13.17
* Update FrequencySketch.scala
2025-09-21 23:01:40 +08:00
He-Pin(kerr)
0ddb7a2ec7
chore: Make val debug final ( #2251 )
2025-09-21 19:39:39 +08:00
He-Pin(kerr)
a1ade992ff
feat: Add Sink#count operator. ( #2244 )
...
* feat: Add Sink#count operator.
* Use .asInstanceOf for better performance
---------
Co-authored-by: Matthew de Detrich <mdedetrich@gmail.com>
2025-09-21 16:15:13 +08:00
He-Pin(kerr)
4f2434b650
chore: Drop @unused annotation from pekko ( #2241 )
2025-09-20 13:28:02 +08:00
He-Pin(kerr)
870d4499cc
chore: sort imports ( #2235 )
2025-09-20 11:30:05 +08:00
He-Pin(kerr)
8254acc0e8
chore: Remove ccompat.JavaConverters ( #2234 )
2025-09-20 01:12:16 +08:00
He-Pin(kerr)
9b2853c730
chore: Use scala.jdk.DurationConverters ( #2205 )
2025-09-20 01:05:11 +08:00
He-Pin(kerr)
875840d3b8
chore: Remove pekko.util.FutureConverters ( #2207 )
...
* chore: Remove pekko.util.FutureConverters
2025-09-20 00:42:52 +08:00
PJ Fanning
04f5fcd1b7
chore: Use Scala Option Converter ( #2203 )
...
* chore: Use Scala Option Converter
---------
Co-authored-by: He-Pin <hepin1989@gmail.com>
2025-09-19 23:34:29 +08:00
He-Pin(kerr)
8c48393cd3
chore: Remove pekko.dispatch.ExecutionContexts.parasitic ( #2208 )
...
* chore: Remove pekko.dispatch.ExecutionContexts.parasitic
* .
2025-09-19 22:17:20 +08:00
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)
47e7e23f2d
chore: make toAttributes a lazy val ( #2157 )
2025-09-06 22:48:52 +08:00
He-Pin(kerr)
61de190fca
chore: Add doc for AsyncCallback ( #2142 )
2025-09-05 05:56:24 +08:00
He-Pin(kerr)
6f2a65da4c
chore: Make use of japi.function in stream api. ( #2143 )
2025-09-05 03:24:26 +08:00
PJ Fanning
70a9f092dd
remove more deprecation annotations by making fields less accessible ( #2136 )
...
* remove more deprecation annotations by making fields less accessible
* Update ActorMaterializer.scala
* Update ActorMaterializer.scala
2025-09-04 03:52:09 +01:00
He-Pin(kerr)
a0f807d05a
chore: Drop ActorMaterializer class. ( #2137 )
2025-09-04 04:55:07 +08:00
He-Pin(kerr)
5db362f58f
chore: Remove the deprecated onDownstreamFinish method in GraphStage ( #2129 )
2025-09-03 03:07:57 +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)
617d1c5faa
chore: Remove the deprecated annotation from recoverWith ( #2119 )
2025-08-31 19:11:49 +08:00
He-Pin(kerr)
39cbb3936e
chore: Test if materializerPromise is already completed first. ( #2117 )
2025-08-31 18:48:47 +08:00
PJ Fanning
5a8e161ec5
use Java CompletionStage instead of Scala Future in pekko-persistence Java APIs ( #2092 )
...
* Don't use Scala Futures in Java APIs
Sketching out #1417 - incomplete and notably not bothering
with binary compatibility yet, just to illustrate the idea.
* javafmt
* javafmt
* Update SnapshotStore.scala
* scalaAnyToUnit
* use ExecutionContexts.parasitic
* Update SnapshotStore.scala
* Update LambdaPersistencePluginDocTest.java
* parasitic
* Update LambdaPersistencePluginDocTest.java
* docs
* recovery
* javafmt
* Update LambdaPersistencePluginDocTest.java
---------
Co-authored-by: Arnout Engelen <arnout@bzzt.net>
2025-08-25 23:30:16 +01:00
He-Pin(kerr)
806d33c90e
chore: Remove OverflowStrategy#dropNew ( #2073 )
2025-08-24 05:24:43 +08:00
He-Pin(kerr)
5a94aa36a0
chore: Remove validateDefaultTrustManager ( #2068 )
2025-08-23 22:01:07 +08:00
He-Pin(kerr)
b146f5f4fc
chore: Remove AbruptIOTerminationException ( #2065 )
2025-08-23 19:59:34 +08:00
PJ Fanning
bd24ae69fd
remove deprecated monitor operation ( #2056 )
...
* remove deprecated monitor operation
* Update remove-deprecated-methods.excludes
2025-08-23 11:39:46 +01:00
He-Pin(kerr)
c346c14660
chore: Remove wrong deprecation in IOResult. ( #2054 )
2025-08-23 16:55:41 +08:00
PJ Fanning
e0619c34fb
generate source with protobuf 32 ( #2036 )
...
* generate source with protobuf 32
* javafmt
2025-08-20 08:21:18 +01: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
7af97edd86
remove deprecated stream operators ( #2017 )
...
* remove deprecated stream operators
* more deprecations
2025-08-08 09:02:08 +01:00
PJ Fanning
fc7ab2b8b5
remove unused code in actormaterializer ( #2016 )
...
* remove unused code in actormaterializer
* Update remove-deprecated-methods.excludes
2025-08-08 09:01:38 +01:00
PJ Fanning
4be8edcae4
try to remove some deprecated materializer methods ( #2011 )
...
* try to remove some deprecated materializer methods
* more changes
* mima
* Update StreamRefSettings.scala
* make deprecated code that can't be deleted package private
* Update StreamRefSettings.scala
* Update ActorMaterializer.scala
2025-08-07 09:36:01 +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
He-Pin(kerr)
08ea94bb4b
chore: Migrate to pekko.japi.function ( #2001 )
...
* chore: Remove javaapi.Function
* chore: Remove javaapi.Function2
* chore: Remove javaapi.Procedure
* chore: Remove javaapi.Predicate
* chore: Remove javaapi.Creator
* chore: Remove javaapi.Effect
* chore: Add mima
* Update actor-typed/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
* Update stream/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
* Update persistence/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
* Update actor/src/main/mima-filters/2.0.x.backwards.excludes/javaapi-functions.excludes
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
---------
Co-authored-by: PJ Fanning <pjfanning@users.noreply.github.com>
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
2025-08-05 10:45:25 +08: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
He-Pin(kerr)
7325c729ce
Make use of eq and ne. ( #1994 )
...
* chore: make use of eq instead of ==
* chore: make use of ne instead of !=
2025-08-03 17:32:32 +08: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
He-Pin(kerr)
7bf6cf4969
=str Switch the type parameter order of UnfoldResourceSourceAsync ( #616 )
2025-08-02 14:48:35 +08:00
PJ Fanning
9e540b1236
remove deprecated names annotations ( #1985 )
2025-07-31 20:03:35 +01:00
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
