# NAME

RxPerl::IOAsync - IO::Async adapter for RxPerl

# SYNOPSIS

   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 a module that lets you use the [RxPerl](https://metacpan.org/pod/RxPerl) Reactive Extensions in your app that uses IO::Async.

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