jox

jox copied to clipboard

Feature Request: Add Non-blocking trySend() and tryReceive() to Channel

1

At least trySend() 🙏 TL;DR Add non-blocking trySend(T) and tryReceive() methods to Channel to enable integration with NIO frameworks (Netty, Vert.x, etc.), where blocking the event loop thread is prohibited....

magicprinc

This PR contains the following updates: | Package | Change | Age | Confidence | |---|---|---|---| | [org.junit.jupiter:junit-jupiter](https://junit.org/) ([source](https://redirect.github.com/junit-team/junit-framework)) | `5.14.1` -> `6.0.1` | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | --- >...

renovate[bot]

For monitoring, metrics and UnlimitedChannels it would be very useful to have Channel.estimateSize() or Channel.size() 🙏

magicprinc

Support micro batching in channels

1

It'd be nice to be able to receive (or send) multiple values at once from the channel, something like `channel.receive(n)`. For the case when `n` elements are not available, there...

asarkar