NAME

RxPerl::Guides::CreatingObservables - A guide to creating your own observables

CREATING YOUR OWN OBSERVABLES

Check out these examples, and draw your own conclusions:

    my $o = rx_observable->new(sub ($subscriber) {
        $subscriber->next(10);
        $subscriber->next(20);
        $subscriber->next(30);
        $subscriber->complete();

        return; # required
    });

Whatever comes after the return keyword will be processed during unsubscription, and will also be processed during observable completion or when it throws an error.

    my $o = rx_observable->new(sub ($subscriber) {
        my $timer = Mojo::IOLoop->timer(5, sub {
            my $temperature = get_temperature_from_sensor();
            $subscriber->next($temperature);
        };

        return sub {
            Mojo::IOLoop->remove($timer);
        };
    });

You can also return an arrayref, a hashref, or a scalar ref, of subroutine refs or RxPerl subscriptions, in any nested configuration (e.g. arrayref of hashrefs of subroutines). Subroutine refs will be executed, subscriptions will be unsubscribed from.

    my $o = rx_observable->new(sub ($subscriber) {
        my $s1 = rx_interval(0.7)->subscribe(sub ($value) {
            $subscriber->next($value);
        });

        my $s2 = rx_interval(1)->subscribe(sub ($value) {
            $subscriber->next($value);
        });

        return [$s1, $s2]; # or even: return { s1 => $s1, s2 => [ \$s2 ] };
    });