# NAME RxPerl::AnyEvent - AnyEvent adapter for RxPerl # SYNOPSIS use RxPerl::AnyEvent ':all'; use AnyEvent; 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)); AnyEvent->condvar->recv; # DESCRIPTION RxPerl::AnyEvent is a module that lets you use the [RxPerl](https://metacpan.org/pod/RxPerl) Reactive Extensions in your AnyEvent app. # DOCUMENTATION The documentation at [RxPerl](https://metacpan.org/pod/RxPerl) applies to this module too. # NOTIFICATIONS FOR NEW RELEASES You can start receiving emails for new releases of this, or other, modules, over at [https://perlmodules.net](https://perlmodules.net). # LICENSE Copyright (C) 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