# 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.

# 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 <[email protected]>

You are viewing proxied material from ftp.icm.edu.pl. The copyright of proxied material belongs to its original authors. Any comments or complaints in relation to proxied material should be directed to the original authors of the content concerned. Please see the disclaimer for more details.