NAME

Ryu::Async - use Ryu with IO::Async

SYNOPSIS

 #!/usr/bin/env perl
 use strict;
 use warnings;
 
 use IO::Async::Loop;
 use Ryu::Async;
 
 use Log::Any::Adapter qw(Stdout), log_level => 'trace';
 
 my $loop = IO::Async::Loop->new;
 $loop->add(
        my $ryu = Ryu::Async->new
 );
 
 {
        my $timer = $ryu->timer(
                interval => 0.10,
        )->take(10)
         ->each(sub { print "tick\n" });
        warn $timer->describe;
        $timer->get;
 }

DESCRIPTION

This is an IO::Async::Notifier subclass for interacting with Ryu.

METHODS

from

Creates a new Ryu::Source from a thing.

The exact details of this are likely to change in future, but a few things that are expected to work:

 $ryu->from($io_async_stream_instance)
     ->by_line
     ->each(sub { print "Line: $_\n" });
 $ryu->from([1..1000])
     ->sum
     ->each(sub { print "Total was $_\n" });

from_stream

Create a new Ryu::Source from an IO::Async::Stream instance.

Note that a stream which is not already attached to an IO::Async::Notifier will be added as a child of this instance.

from_stream

Create a new Ryu::Source that wraps STDIN.

As with other IO::Async::Stream wrappers, this will emit data as soon as it's available, as raw bytes.

Use "by_line" in Ryu::Source and "decode" in Ryu::Source to split into lines and/or decode from UTF-8.

stdout

Returns a new Ryu::Sink that wraps STDOUT.

timer

Provides a Ryu::Source which emits an empty string at selected intervals.

Takes the following named parameters:

• interval - how often to trigger the timer, in seconds (fractional values allowed)

• reschedule - type of rescheduling to use, can be soft, hard or drift as documented in IO::Async::Timer::Periodic

Example:

 $ryu->timer(interval => 1, reschedule => 'hard')
     ->combine_latest(...)

run

Creates an IO::Async::Process.

source

Returns a new Ryu::Source instance.

udp_client

Creates a new UDP client.

This will return a Ryu::Async::Connection instance, which provides a sink for outgoing packets, and a source for incoming responses.

udp_server

sink

Returns a new Ryu::Sink.

The label will default to the calling package/class and method, with some truncation rules:

• A Net::Async:: prefix will be replaced by Na.

• A Web::Async:: prefix will be replaced by Wa.

• A IO::Async:: prefix will be replaced by Ia.

• A Tickit::Async:: prefix will be replaced by Ta.

• A Tickit::Widget:: prefix will be replaced by TW.

This list of truncations is subject to change, so please don't rely on any of these in string matches or similar - better to set your own label if you need consistency.

SEE ALSO

• Ryu

• IO::Async

AUTHOR

Tom Molesworth <TEAM@cpan.org>

LICENSE

Copyright Tom Molesworth 2011-2017. Licensed under the same terms as Perl itself.

cpanm Ryu::Async

perl -MCPAN -e shell
install Ryu::Async