source:
node_modules/pg-protocol/src/index.ts
| Last change on this file was 62b2964, checked in by , 2 weeks ago | |
|---|---|
|
|
| File size: 443 bytes | |
| Rev | Line | |
|---|---|---|
| [62b2964] | 1 | import { DatabaseError } from './messages' |
| 2 | import { serialize } from './serializer' | |
| 3 | import { Parser, MessageCallback } from './parser' | |
| 4 | ||
| 5 | export function parse(stream: NodeJS.ReadableStream, callback: MessageCallback): Promise<void> { | |
| 6 | const parser = new Parser() | |
| 7 | stream.on('data', (buffer: Buffer) => parser.parse(buffer, callback)) | |
| 8 | return new Promise((resolve) => stream.on('end', () => resolve())) | |
| 9 | } | |
| 10 | ||
| 11 | export { serialize, DatabaseError } |
Note:
See TracBrowser
for help on using the repository browser.
