Skip to content

Commit 0822e4d

Browse files
authored
fix: pipe metadata along (#1178)
* pipe metadata along * Arrange imports back to where they were * revert some automatic imports * revert automatic import * report metadata when it doesn’t exist yet * should include metadata in result * Remove only * Removed setting metadata that is no longer used * Add an assert fail * Better check for metadata * use bind instead * revert changes for exposing metadata directly * change stream emit metadata back
1 parent dc3f9a0 commit 0822e4d

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/index.ts

+4
Original file line numberDiff line numberDiff line change
@@ -863,6 +863,7 @@ export class Bigtable {
863863
gaxStream = requestFn!();
864864
gaxStream
865865
.on('error', stream.destroy.bind(stream))
866+
.on('metadata', stream.emit.bind(stream, 'metadata'))
866867
.on('request', stream.emit.bind(stream, 'request'))
867868
.pipe(stream);
868869
});
@@ -879,6 +880,9 @@ export class Bigtable {
879880
.on('error', (err: Error) => {
880881
stream.destroy(err);
881882
})
883+
.on('metadata', metadata => {
884+
stream.emit('metadata', metadata);
885+
})
882886
.on('response', response => {
883887
stream.emit('response', response);
884888
})

0 commit comments

Comments
 (0)