pekko
pekko copied to clipboard
POC +str Add StreamCollector api for unsafe transformation.
Motivation: Make it simpler when integrating with other effect system.
When reading : https://alexn.org/blog/2023/04/17/integrating-akka-with-cats-effect-3/ ; I think there should be a simpler api to integrate other effect system ,which does not need to transform back to Future.
The unsafeTransform can be implemented in similar way.
refs: https://github.com/typelevel/cats-effect/issues/3807
Related work: https://github.com/akka/akka/pull/28674 from @jrudolph
And the unsafeTransform can be implemented in similar way
Notes:
- This is a quick POC and the api need more polish, as the
unsafestatements, it's unsafe. - This is not a
F[_]typeclass implementation.
@alexandru ping
Also pinging @jrudolph because he did prior work on this
Now JDK22 ships a Gather https://openjdk.org/jeps/461