File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -193,12 +193,12 @@ var clientBuilder = function(config) {
193
193
connection . _pulseQueryQueue ( ) ;
194
194
}
195
195
} ) ;
196
- connection . on ( '_copyInResponse ' , function ( ) {
196
+ connection . on ( 'copyInResponse ' , function ( ) {
197
197
//connection is ready to accept chunks
198
198
//start to send data from stream
199
199
connection . _activeQuery . streamData ( connection ) ;
200
200
} ) ;
201
- connection . on ( '_copyData ' , function ( chunk ) {
201
+ connection . on ( 'copyData ' , function ( chunk ) {
202
202
//recieve chunk from connection
203
203
//move it to stream
204
204
connection . _activeQuery . handleCopyFromChunk ( chunk ) ;
Original file line number Diff line number Diff line change @@ -439,7 +439,7 @@ class Connection : public ObjectWrap {
439
439
while ((result = PQgetResult (connection_))) {
440
440
if (PGRES_COPY_IN == PQresultStatus (result)) {
441
441
didHandleResult = false ;
442
- Emit (" _copyInResponse " );
442
+ Emit (" copyInResponse " );
443
443
PQclear (result);
444
444
break ;
445
445
} else if (PGRES_COPY_OUT == PQresultStatus (result)) {
@@ -483,7 +483,7 @@ class Connection : public ObjectWrap {
483
483
if (copied > 0 ) {
484
484
Buffer * chunk = Buffer::New (buffer, copied);
485
485
Handle <Value> node_chunk = chunk->handle_ ;
486
- Emit (" _copyData " , &node_chunk);
486
+ Emit (" copyData " , &node_chunk);
487
487
PQfreemem (buffer);
488
488
// result was not handled copmpletely
489
489
return false ;
You can’t perform that action at this time.
0 commit comments