He-Pin
Follow
Pinned
415 contributions in the last year
Less
More
Contribution activity
September 2022
Created 38 commits in 4 repositories
Created 6 repositories
- He-Pin/kotlin-plugin Scala
- He-Pin/kotlin-web-site JavaScript
- He-Pin/enso Rust
- He-Pin/strymonas Scala
- He-Pin/sbt-flaky Scala
- He-Pin/gitpod TypeScript
Created a pull request in akka/akka that received 25 comments
=str Optimize performance of MapAsyncUnordered(1).
Run with
jmh:run -i 20 -wi 20 -f1 -t1 .MapAsyncBenchmark.
I adjusted it a little to just run with 1.
jmh:run -i 20 -wi 20 -f1 -t1 .MapAsyncOneBe…
+446
−9
•
25
comments
Opened 38 other pull requests in 4 repositories
akka/akka
11
closed
5
open
19
merged
- backport to release-2.6 =str Fix statefulMap to not call onComplete twice.
- =str Make SingleConsumerMultiProducer the default mailbox for stream.
- !str filter out elements without demands for Flow#collect operator.
- =sbt Bump Scala version to 2.12.17 & 2.13.9.
- =str Use java.util.function.* in mapWithResource instead.
- !str Mark SubFlow and SubSource final.
- Optimize flatMapConcat for iterable and empty source.
- =str Update mima for GraphStageLogic.onFeedbackDispatched.
- =str Update MapWithResourceSpec to request 1 to fix #31585.
- try cross compile with Scala 3.2.0 No need review.
- =act Make akka compiles on scala 3.1.3 & 3.2.0
- =str Reduce one field in MapAsyncUnordered.
- Add Fold with resource for Sink
- little Refactoring to unfoldResource
- =str try to remove FanOutProcessorImpl.
- =str Make Source.range simpler.
- =str Update FlowMergeAllSpec because the merge order is undefined.
- !str Drop the IODispatcher attribute of OutputStreamSourceStage.
- !str Drop the IODispatcher attribute of InputStreamSinkStage.
- =str Fold InHandler and OutHandler for operator ActorRefBackpressureS…
- =str Fold InHandler and OutHandler for operator ActorRefSource.
- =str Fold InHandler and OutHandler for operator FlatMapPrefix.
- =str Fold InHandler and OutHandler for FutureFlow.
- =str Fold InHandler and OutHandler for operator LazySource.
- =str Fold InHandler and OutHandler for TcpStreamLogic.
- Some pull requests not shown.
akka/akka-http
1
open
JetBrains/kotlin-web-site
1
open
LesnyRumcajs/grpc_bench
1
merged
Reviewed 24 pull requests in 3 repositories
akka/akka
21 pull requests
- !str filter out elements without demands for Flow#collect operator.
- chore: Small optimization of the actor graph interpreter
- =str Make SingleConsumerMultiProducer the default mailbox for stream.
- add missing .withAllocationStrategy(ExternalShardAllocationStrategy) example for Java
- typed javadsl: introduce AbstractOnMessageBehavior
- =act Optimize BehaviorBuilder and ReceiveBuilder's built behavior wit…
- Add Fold with resource for Sink
- Introduce statefulMapAsync operator
- Optimize flatMapConcat for iterable and empty source.
- +str Add combine seq method to Source and Sink
- =str Optimize performance of MapAsyncUnordered(1).
- =act Make akka compiles on scala 3.1.3 & 3.2.0
- =str Update MapWithResourceSpec to request 1 to fix #31585.
- little Refactoring to unfoldResource
- =str Reduce one field in MapAsyncUnordered.
- try cross compile with Scala 3.2.0 No need review.
- =str try to remove FanOutProcessorImpl.
- Change license
- =str Fold InHandler and OutHandler for operator RetryFlowCoordinator.
- Add mapWithResource
- =str Update FlowMergeAllSpec because the merge order is undefined.
lightbend/kalix-jvm-sdk
2 pull requests
akka/akka-platform-guide
1 pull request
Created an issue in lampepfl/dotty that received 7 comments
Type computed to any, works in Scala 2
Compiler version 3.1.2 Rrror: https://github.com/akka/akka/runs/8294129202?check_suite_focus=true From: akka/akka#31345 Minimized code Sorry I have…
7
comments
Opened 26 other issues in 7 repositories
akka/akka
15
open
5
closed
- backport to release-2.6: Fix statefulMap to not call onComplete twice.
- Add a Flow#handle?
- Deprecate statefulMapConcat
- adds cancellation of the source future support
- Add some scaladoc about ContextPropagation?
- Feature request: optimize akka with loom
- Use java.util.function.* in mapWithResource javadsl
-
Should
createbe called only there is a pull, inUnfoldResourceSourceUnfoldResourceSourceAsyncandStatefulMap? - Add BoundedSourceQueue.isQueueCompleted to check is the queue is completed before offering?
-
SupervisedGraphStageLogic allocates
Someper element - Collect can not filter out elements without demand.
- Akka docs render error: Output port
- Failed: MapWithResourceSpec.MapWithResource must fail when close throws exception
- Failed: mapWithResource must use dedicated blocking-io-dispatcher by default
- SubFlow and SubSource in javadsl should be final class.
-
Feature request: Add
mask/onErrorComplete/recoverWithComplete? - Feature request: Add some more stream operators (meta issue)
- Add common trait for AbruptTerminationException and AbruptStageTerminationException?
- Failed: FlowMergeAllSpec——must merge all elements of the first completed source to its downstream
- Faild: RetryFlowSpec——exponentially backoff between retries
scala/bug
1
closed
typelevel/fs2
1
open
lampepfl/dotty
1
open
sbt/sbt
1
open
scala-native/scala-native
1
open
sbt/sbt-boilerplate
1
open
Started 1 discussion in 1 repository
mdedetrich/akka-apache-project
mdedetrich/akka-apache-project
-
How to sync features between projects?
This contribution was made on Sep 26