[dbsrgits/DBIx-Data-Store-old.git] / lib / DBIx / Data / Stream / STH.pm

package DBIx::Data::Stream::STH;

use Moose;
use Method::Signatures::Simple;

has 'sth' => (is => 'ro', required => 1, clearer => '_clear_sth');

method next {
  my $sth = $self->sth;
  return unless $sth;
  # {Active} only means that there *may* be more results to fetch
  if ($sth->{Active} and my @next = $self->sth->fetchrow_array) {
    return \@next;
  }
  $sth->finish;
  # prepare_cached might recycle it now we're finished so get rid of it
  $self->_clear_sth;
  return;
}

__PACKAGE__->meta->make_immutable;

1;
Commit	Line	Data
65b76960	1	package DBIx::Data::Stream::STH;
	2
	3	use Moose;
	4	use Method::Signatures::Simple;
	5
	6	has 'sth' => (is => 'ro', required => 1, clearer => '_clear_sth');
	7
	8	method next {
	9	my $sth = $self->sth;
	10	return unless $sth;
	11	# {Active} only means that there may be more results to fetch
	12	if ($sth->{Active} and my @next = $self->sth->fetchrow_array) {
	13	return \@next;
	14	}
	15	$sth->finish;
	16	# prepare_cached might recycle it now we're finished so get rid of it
	17	$self->_clear_sth;
	18	return;
	19	}
	20
	21	__PACKAGE__->meta->make_immutable;
	22
	23	1;