/ 
Async-Stream-0.12
River stage zero No dependents
/ Async::Stream::Pushable

NAME

Use that class for creating streams which you can use to push item to them.

VERSION

Version 0.11

SYNOPSIS

Creating pushable streams, you can use this type of streams for example for observer pattern

use Async::Stream::Pushable;

my $stream = Async::Stream::Pushable->new;

$stream->push(1,2,3)->finalize;

# Or for example

my $stream = Async::Stream::Pushable->new;

$some_object->subscribe(sub {
    my $new_item = shift;
    $stream->push($new_item);
  });

SUBROUTINES/METHODS

new(@array_of_items)

Constructor creates instance of class. Class method create stream which you can use that to push items to that.

my $stream = Async::Stream::Pushable->new(@urls)

push(@new_items)

Push new items to stream

my $stream->push(@new_items);

finalize()

Finalize stream

my $stream->finalize;

AUTHOR

Kirill Sysoev, <k.sysoev at me.com>

BUGS AND LIMITATIONS

Please report any bugs or feature requests to https://github.com/pestkam/p5-Async-Stream/issues.

SUPPORT

You can find documentation for this module with the perldoc command.

perldoc Async::Stream::Item

LICENSE AND COPYRIGHT

Copyright 2017 Kirill Sysoev.

This program is free software; you can redistribute it and/or modify it under the terms of the the Artistic License (2.0). You may obtain a copy of the full license at:

http://www.perlfoundation.org/artistic_license_2_0