diff --git a/src/index.ts b/src/index.ts index 5f01e2a4d..80bc710d5 100644 --- a/src/index.ts +++ b/src/index.ts @@ -863,6 +863,7 @@ export class Bigtable { gaxStream = requestFn!(); gaxStream .on('error', stream.destroy.bind(stream)) + .on('metadata', stream.emit.bind(stream, 'metadata')) .on('request', stream.emit.bind(stream, 'request')) .pipe(stream); }); @@ -879,6 +880,9 @@ export class Bigtable { .on('error', (err: Error) => { stream.destroy(err); }) + .on('metadata', metadata => { + stream.emit('metadata', metadata); + }) .on('response', response => { stream.emit('response', response); })