43 type ChangeStream struct {  struct
75 	opts ...*options.ChangeStreamOptions) (*ChangeStream, error) {
80 	cs := &ChangeStream{
160 func (cs *ChangeStream) executeOperation(ctx context.Context, resuming bool) error {  argument
261 func (cs *ChangeStream) updatePbrtFromCommand() {  argument
268 func (cs *ChangeStream) storeResumeToken() error {  argument
291 func (cs *ChangeStream) buildPipelineSlice(pipeline interface{}) error {  argument
325 func (cs *ChangeStream) createPipelineOptionsDoc() bsoncore.Document {  argument
367 func (cs *ChangeStream) pipelineToBSON() (bsoncore.Document, error) {  argument
378 func (cs *ChangeStream) replaceOptions(ctx context.Context, wireVersion *description.VersionRange) {  argument
408 func (cs *ChangeStream) ID() int64 {  argument
417 func (cs *ChangeStream) Decode(val interface{}) error {  argument
426 func (cs *ChangeStream) Err() error {  argument
439 func (cs *ChangeStream) Close(ctx context.Context) error {  argument
457 func (cs *ChangeStream) ResumeToken() bson.Raw {  argument
468 func (cs *ChangeStream) Next(ctx context.Context) bool {  argument
483 func (cs *ChangeStream) TryNext(ctx context.Context) bool {  argument
487 func (cs *ChangeStream) next(ctx context.Context, nonBlocking bool) bool {  argument
517 func (cs *ChangeStream) loopNext(ctx context.Context, nonBlocking bool) {  argument
557 func (cs *ChangeStream) emptyBatch() bool {  argument