NAME Ryu::Async - use Ryu with IO::Async SYNOPSIS #!/usr/bin/env perl use strict; use warnings; use IO::Async::Loop; use Ryu::Async; # This will generate a lot of output, but is useful # for demonstrating lifecycles. Drop this to 'info' or # 'debug' to make it more realistic. 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. stdin 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 provides a sink for "outgoing" in Ryu::Async::Client packets, and a source for "incoming" in Ryu::Async::Client responses. * uri - an optional URI of the form udp://host:port * host - which host to listen on, defaults to 0.0.0.0 * port - the port to listen on Returns a Ryu::Async::Client instance. 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 Database::Async:: prefix will be replaced by Da. * 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-2019. Licensed under the same terms as Perl itself.