view release on metacpan or  search on metacpan

lib/Async/Stream/FromArray.pm  view on Meta::CPAN

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

=cut

sub new {
	my $class = shift;
	my $items = \@_;

	return $class->SUPER::new(
		sub { 
			$_[0]->( @{$items} ? (shift @{$items}) : () );
			return;
		}
	);
}


=head1 AUTHOR

lib/Async/Stream/Pushable.pm  view on Meta::CPAN

Class method create stream which you can use that to push items to that.

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

=cut

sub new {
	my $class = shift;

	my $self;
	$self = $class->SUPER::new(
		sub {
			my ($return_cb) = @_;

			if (@{$self->{_items}}) {
				$return_cb->(shift @{ $self->{_items} });
			} else {
				if ($self->{_is_finalized}){
					$return_cb->();
				}
				else {