RxJava

Reactive eXtensions for composing async and event-driven programs using observable sequences for the Java VM.

@akarnokd

[RxJava @RxJava]

I've setup a Discord server to discuss RxJava 4 and support earlier versions in a more real-time fashion.

👉 https://t.co/fxBNs8KFSz

Will tune the server and topics as needed.

💿or'd 👑@akarnokd

[RxJava @RxJava]

We are now in a time where there is a serious chance yours truly will be banned or heavily restricted on GitHub, the private platform that can do anything they want without checks and balances, no transparency.

I'll be arranging backups, but mainly I prepare to move the RxJava project into my institute's own GitLab repository:

https://t.co/zgXkNK7Ih7

(please wait for the permissions to go live).

🫡 @akarnokd

[RxJava @RxJava]

RxJava v4.0.0-alpha-13 released!����

💿 or'd 🗨️ https://t.co/KizCwsV0FJ

Changelog 🫴 https://t.co/g58pFn17bR

🫡 @akarnokd

[David Karnok @akarnokd]

Who. Cares.

Please add compiler conveniences such as extension methods, async-await, generator syntax for iterable/async-streams, auto Varhandles, in Java 27+.

Please. Stop fooling around and consider the community's needs. Any of our needs.

AI assist will help you resolve issues and corner cases.

Please 🥺

[RxJava @RxJava]

Disclaimer

The new profile picture is generated via @Grok based on the Elf-comics of @merrivius as if the Elf would talk to our ReactiveX eel in a snarky way.

🫡 @akarnokd

[Francesco Nigro @forked_franz]

@akarnokd HI David, did you take a look at https://t.co/KCbhK7a7Px and https://t.co/yZxrHFiCod ?

TLDR it enables running blocking operations AND any reactive pipeline on the same carriers - including ones which run Netty I/O without using the FJ pool.
I'm working on ... (1/2)

[David Karnok @akarnokd]

Wow. Interesting thesis.

https://t.co/PtLZ7J5YNu

If you can, please redo it with #RxJava 4's Schedulers.virtual() instead of wasting 1,000+ cached threads on blocking IO at once.

Also it is not explicitly mentioned by the document, but Structured Concurrency won't save you much.

Coordination is one of the hardest part of async programming and you'll sweat blood getting it to work for non-trivial and/or multi-valued use cases.

I know, because I did sweat.

Worry not. We'll fix that with Streamable<T> / Streamer<T> just fine.

😏Stay tuned!

[RxJava @RxJava]

RxJava v4.0.0-alpha-12 released!🤘

💿 or'd 🗨️ https://t.co/KizCwsVyvh

Changelog 🫴 https://t.co/CZzl8z2Icc

🫡 @akarnokd

[RxJava @RxJava]

RxJava v4.0.0-alpha-11 released!🤘

💿 or'd 🗨️ https://t.co/KizCwsV0FJ

Changelog 🫴 https://t.co/N1u7jIOApS

🫡 @akarnokd

[RxJava @RxJava]

RxJava v4.0.0-alpha-10 released!🤘

💿 or'd 🗨️ https://t.co/KizCwsVyvh

Changelog 🫴 https://t.co/twJ9EUE0NP

🫡 @akarnokd

[RxJava @RxJava]

RxJava v4.0.0-alpha-9 released!🤘

💿 or'd 🗨️ https://t.co/KizCwsV0FJ

Changelog 🫴 https://t.co/kd9Q37XGSK

🫡 @akarnokd

[RxJava @RxJava]

RxJava v4.0.0-alpha-8 released!🤘

💿 or'd 🗨️ https://t.co/KizCwsV0FJ

Changelog 🫴 https://t.co/JBZPUrJ78C

🫡 @akarnokd

[David Karnok @akarnokd]

#java #idea #rxjava
Here is my list of Java language enhancements that would make our RxJava life much much easier:

- Extension methods.
- Generators á la C#, yield return X and yield return async X.
- Syntactic sugar async/await on top of Virtual Threads
- Syntactic sugar atomics, atomic_read(x), atomic_cmpxchg(x), etc.
- Obtaining names via nameof(method|param|variable) at compile time.

These all seem to be doable, and anomalies worked around just fine. Please do it. Please.

🥺🙏

[David Karnok @akarnokd]

#rxjava #proposal
I've just posted a new hybrid reactive-virtual type Streamable<T> and its provider Streamer<T>.

It is a multi-valued sequence that complements the executor.submit() type one-shot calls with Virtual Threads.

It is going to be modelled after C#'s IAsyncEnumerable<T> type.

Virtual threads make it very convenient to block on join() calls.

However, I'd rather have syntactic sugar support in Java: await someCompletionStage;. Any state machine builder for yield return and yield return async would be also welcome.

https://t.co/SM2U7nHkby

[RxJava @RxJava]

RxJava v4.0.0-alpha-7-2 released!🤘

💿 or'd 🗨️ https://t.co/KizCwsVyvh

Changelog 🫴 https://t.co/RKdVeXL4RN

🫡 @akarnokd

[David Karnok @akarnokd]

RxJava 4.0.0-alpha-7 released!🤘

💿 or'd 🗨️ https://t.co/0qS96kUDa3

Changelog 🫴 https://t.co/rF4Mj2nLz7

🫡 @akarnokd

[RxJava @RxJava]

RxJava 4.0.0-alpha-6 released!🤘

💿or'd 🗨️ https://t.co/KizCwsV0FJ

Changelog 🫴 https://t.co/5JtPwqp3C9

🫡 @akarnokd

[RxJava @RxJava]

Hi @merrivius !

I'm @akarnokd, the maintainer of @RxJava, https://t.co/RzbemM8XzD, the project lead.

Would you be willing to create for us an Elf-comic style RxJava-eel, snarky, you know, image to become the @RxJava X/Discord header/banner?

Of course, please name the price.

We are a free OSS project, so I'll have to pay from my own pocket. Anywhere between $100 - $300 sounds good? Via bank transfer.

[RxJava @RxJava]

RxJava 4.0.0-alpha-5 released!🤘

💿or'd 🗨️ https://t.co/KizCwsV0FJ

Changelog 🫴 https://t.co/0xpBkjB7Or

🫡 @akarnokd