13 Commits

Author SHA1 Message Date
matthew.blasius
d1ac31c105 Support a close callback when closing the stream 2015-11-05 16:54:12 -05:00
matthew.blasius
68819dffda Avoid race when stream closed while fetching 2015-11-05 14:09:50 -05:00
Brian M. Carlson
6ab80d3995 Add close method & supporting tests 2014-10-30 18:38:44 -04:00
Calvin Metcalf
fec090972b clean ups 2014-05-14 10:41:10 -04:00
Tom Buchok
cab956ba50 passes stream-tester-timestamp
- moves 'end' event listener to constructor, only listen once
- ensures all existing tests still green
2014-04-09 23:58:18 -04:00
Brian M. Carlson
37de9c2ab0 Rebase code on top of pg-cursor 2014-02-26 09:38:16 -06:00
Brian M. Carlson
b66be5e934 Add test for stream close & satisfy stream contract 2014-02-26 07:15:01 -06:00
Stephen Sugden
e1117155ae Emit 'close' events when query completes
Consider a system where one component is scheduling tasks that yield
streams, and passing them to (unknown) clients for consumption.

It would be useful for the scheduler to know that the query
underlying the stream is completed (so it can continue on to it's
next task) without having to wait for the consumer to finish reading
all results.
2013-12-25 13:33:34 -08:00
Brian M. Carlson
33be525dbb Add ability to configure highWaterMark and batchSize 2013-10-23 17:11:43 -05:00
Brian M. Carlson
1b249e9ceb Add in proper error handling 2013-10-22 13:19:28 -05:00
Brian M. Carlson
48687fc182 Fix relative load path for pg.js 2013-10-22 11:36:05 -05:00
Brian M. Carlson
5400dfeffd Remove bad code 2013-10-22 11:24:30 -05:00
Brian M. Carlson
722296f8d2 Initial commit 2013-10-21 23:57:50 -05:00