# NAME

RxPerl::Mojo - Mojo::IOLoop adapter for RxPerl

# SYNOPSIS

   use RxPerl::Mojo ':all';
   use Mojo::IOLoop;

   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));

   Mojo::IOLoop->start;

# DESCRIPTION

RxPerl::Mojo is a module that lets you use the [RxPerl](https://metacpan.org/pod/RxPerl) Reactive Extensions in your Mojolicious app
or app that uses Mojo::IOLoop.

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