Fix pg-query-stream by adding a compatible overload to query() (#15351)

This commit is contained in:
António Marques
2017-03-24 07:44:32 -07:00
committed by Andy
parent cc585590b1
commit 55bf786d3b
3 changed files with 8 additions and 3 deletions
+5 -1
View File
@@ -3,6 +3,10 @@
// Definitions by: António Marques <https://github.com/asmarques>
// Definitions: https://github.com/DefinitelyTyped/DefinitelyTyped
/// <reference types="node" />
import stream = require("stream");
declare namespace QueryStream {
interface Options {
highWaterMark?: number;
@@ -10,7 +14,7 @@ declare namespace QueryStream {
}
}
declare class QueryStream {
declare class QueryStream extends stream.Readable {
batchSize: number;
text: string;
values?: any[];
+2 -2
View File
@@ -10,10 +10,10 @@ const query = new QueryStream('SELECT * FROM generate_series(0, $1) num', [10000
pg.connect('', (err, client, done) => {
const stream = client.query(query);
stream.then(() => {
stream.on('end', () => {
client.end();
});
stream.then((data: any) => {
stream.on('data', (data: any) => {
console.log(data);
});
});
+1
View File
@@ -89,6 +89,7 @@ export declare class Client extends events.EventEmitter {
end(callback?: (err: Error) => void): void;
release(): void;
query(queryStream: QueryConfig & stream.Readable): stream.Readable;
query(queryTextOrConfig: string | QueryConfig): Promise<QueryResult>;
query(queryText: string, values: any[]): Promise<QueryResult>;