RxPerl::IOAsync(3pm)

🌸 NAME 🌸

okay so bestie, welcome to the user-contributed Perl documentation page for RxPerl::IOAsync(3pm) — the one and only RxPerl::IOAsync 💖. It's the IO::Async adapter for RxPerl, and yes that's the whole name vibe. Periodt.

---

✨ SYNOPSIS ✨

Here's the little demo, copied exactly because code is sacred:

use RxPerl::IOAsync ':all';
use IO::Async::Loop;

my $loop = IO::Async::Loop->new;
RxPerl::IOAsync::set_loop($loop);

sub make_observer ($i) {
    return {
        next     => sub {say "next #$i: ", $_[0]},
        error    => sub {say "error #$i: ", $_[0]},
        complete => sub {say "complete #$i"},
    };
}

my $o = rx_interval(0.7)->pipe(
    op_map(sub {$_[0] * 2}),
    op_take_until( rx_timer(5) ),
);

$o->subscribe(make_observer(1));

$loop->run;

---

💅 DESCRIPTION 💅

RxPerl::IOAsync is literally the module that lets you use the RxPerl Reactive Extensions in your app that uses IO::Async. Slay. That's it, that's the job. No cap.

---

📚 DOCUMENTATION 📚

The docs at RxPerl apply to this module too, bestie. So go read those if you need the full tea. 💖

---

📬 NOTIFICATIONS FOR NEW RELEASES 📬

You can start receiving emails for new releases of this module — or other modules — over at https://perlmodules.net. Not me hyping up your inbox, but it's there. ✨

---

🫶 COMMUNITY CODE OF CONDUCT 🫶

The Community Code of Conduct can be found here. That's the whole note, bestie. 🫶

---

📜 LICENSE 📜

Copyright (C) 2020 Karelcom OÜ.

This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.

---

👑 AUTHOR 👑

Alexander Karelas <karjala@cpan.org> — icon behavior, honestly. 👑

mwah 💋 — source/version check: perl v5.42.2, dated 2026-02-15. bye bestie 🫶