Fix: error on decoding using a change stream cursor on a database

Shivam010 · Shivam010 · commit 43d935511ed6 · 2018-12-13T20:57:04.000+05:30
diff --git a/mongo/change_stream.go b/mongo/change_stream.go
@@ -451,7 +451,7 @@ func (cs *changeStream) Decode(out interface{}) error {
 		return err
 	}
 
-	return bson.UnmarshalWithRegistry(cs.coll.registry, br, out)
+	return bson.UnmarshalWithRegistry(cs.db.registry, br, out)
 }
 
 func (cs *changeStream) DecodeBytes() (bson.Raw, error) {

Original file line number	Diff line number	Diff line change
`@@ -451,7 +451,7 @@ func (cs *changeStream) Decode(out interface{}) error {`
`451`	`451`	`return err`
`452`	`452`	`}`
`453`	`453`
`454`		`- return bson.UnmarshalWithRegistry(cs.coll.registry, br, out)`
	`454`	`+ return bson.UnmarshalWithRegistry(cs.db.registry, br, out)`
`455`	`455`	`}`
`456`	`456`
`457`	`457`	`func (cs *changeStream) DecodeBytes() (bson.Raw, error) {`