He-Pin(kerr)
He-Pin(kerr)
We are currently using Spring-Ai and MCP SDK at work, which are totally built the the reactor-core. I always wondered, why can't it be Pekko-stream. And nowadays, the virtual thread...
@mdedetrich You can give it a try, this code will work ok if the event loop is a virtual thread; otherwise, dead deadlock. https://github.com/netty/netty/discussions/15405 At work, Ajdk( a JDK backed...
When you are running inside a Virtual thread, and then you are blocked by, let's say, a Lock, and then the virtual thread is parked and unmounted, so the carrier...
1. There's already a declaration here. 2. Java 25 is coming soon, and managed blocking is a thing of the past. 3. The API needs to be kept simple and...
Kotlin's coroutines are fake, even worse than Java 21's virtual threads. I added this API quite cautiously. You see, I didn't add toOutputStream to Sink. If other libraries had these...
If we have an `AsyncStream/AsyncQueue`, then the problem can be simpler, which pulls always return a Future.
1. Is that true? then why it's not the 1st of the JVM in https://github.com/LesnyRumcajs/grpc_bench/discussions/441 ? 2. it will require a Dispatchers.io to run the blocking code, let kotlin to...
@mdedetrich maybe a new run will show some different.
Btw, there are already a `Source#fromJavaStream` so it's fair to have a `Sink#asJavaStream` too.
But reactor-core has that on Flux and no problem.