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 Reactive Extensions in your Mojolicious app or app that uses Mojo::IOLoop.

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