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>