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 Reactive Extensions in your AnyEvent app.
DOCUMENTATION
The documentation at RxPerl applies to this module too.
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
KARJALA <karjala@cpan.org>