Commit b191b70

committed

Update change stream pipe

1 parent a82e194 commit b191b70Copy full SHA for b191b70

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -138,7 +138,7 @@ async function monitorListingsUsingStreamAPI(client, timeInMs = 60000, pipeline`
`138`	`138`	`const changeStream = collection.watch(pipeline);`
`139`	`139`
`140`	`140`	`// See https://mongodb.github.io/node-mongodb-native/3.6/api/ChangeStream.html#pipe for the pipe() docs`
`141`		`- changeStream.pipe(`
	`141`	`+ changeStream.stream().pipe(`
`142`	`142`	`new stream.Writable({`
`143`	`143`	`objectMode: true,`
`144`	`144`	`write: function (doc, _, cb) {`

Comments

(0)