Skip Menu |

This queue is for tickets about the AnyEvent-CouchDB CPAN distribution.

Report information
The Basics
Id: 70425
Status: resolved
Priority: 0/
Queue: AnyEvent-CouchDB

People
Owner: Nobody in particular
Requestors: mike [...] namimedia.com
Cc:
AdminCc:

Bug Information
Severity: (no value)
Broken in: (no value)
Fixed in: (no value)



Subject: AnyEvent::CouchDB::Stream enhancement
Date: Mon, 22 Aug 2011 14:26:39 -0700
To: bug-AnyEvent-CouchDB [...] rt.cpan.org
From: Michael Henson <mike [...] namimedia.com>
The key changes API parameter we need on AnyEvent::CouchDB::Stream isn't handled: === patch === --- AnyEvent/CouchDB/Stream.pm 2011-07-13 12:35:27.000000000 -0700 +++ AnyEvent/CouchDB/Stream.pm 2011-08-22 14:20:05.631695186 -0700 @@ -17,6 +17,7 @@ my $db = delete $args{database}; my $timeout = delete $args{timeout}; my $filter = delete $args{filter}; + my $since = delete $args{since} my $on_change = delete $args{on_change}; my $on_error = delete $args{on_error} || sub { die @_ }; my $on_eof = delete $args{on_eof} || sub { }; @@ -26,7 +27,7 @@ my $uri = URI->new($server); $uri->path( $db. '/_changes' ); - $uri->query_form( filter => $filter, feed => "continuous" ); + $uri->query_form( filter => $filter, feed => "continuous", since => $since ); my $self = bless {}, $class; === patch === -- Michael Henson mike@namimedia.com Senior Software Engineer Nami Media, Inc.
Michael, Sorry for the late reply. I have applied your patch, and I'll be making a release soon. I had a few other tickets come in for this module last week, so those will be in the next release, too. On Mon Aug 22 17:32:22 2011, mike@namimedia.com wrote: Show quoted text
> The key changes API parameter we need on AnyEvent::CouchDB::Stream isn't > handled: > > > === patch === > --- AnyEvent/CouchDB/Stream.pm 2011-07-13 12:35:27.000000000 -0700 > +++ AnyEvent/CouchDB/Stream.pm 2011-08-22 14:20:05.631695186 -0700 > @@ -17,6 +17,7 @@ > my $db = delete $args{database}; > my $timeout = delete $args{timeout}; > my $filter = delete $args{filter}; > + my $since = delete $args{since} > my $on_change = delete $args{on_change}; > my $on_error = delete $args{on_error} || sub { die @_ }; > my $on_eof = delete $args{on_eof} || sub { }; > @@ -26,7 +27,7 @@ > > my $uri = URI->new($server); > $uri->path( $db. '/_changes' ); > - $uri->query_form( filter => $filter, feed => "continuous" ); > + $uri->query_form( filter => $filter, feed => "continuous", since => > $since ); > > my $self = bless {}, $class; > === patch === > >