66 type ChangeStream struct {  struct
100 	opts ...*options.ChangeStreamOptions) (*ChangeStream, error) {
105 	cs := &ChangeStream{
189 func (cs *ChangeStream) createOperationDeployment(server driver.Server, connection driver.Connectio…  argument
197 func (cs *ChangeStream) executeOperation(ctx context.Context, resuming bool) error {  argument
293 func (cs *ChangeStream) updatePbrtFromCommand() {  argument
300 func (cs *ChangeStream) storeResumeToken() error {  argument
323 func (cs *ChangeStream) buildPipelineSlice(pipeline interface{}) error {  argument
357 func (cs *ChangeStream) createPipelineOptionsDoc() bsoncore.Document {  argument
399 func (cs *ChangeStream) pipelineToBSON() (bsoncore.Document, error) {  argument
410 func (cs *ChangeStream) replaceOptions(ctx context.Context, wireVersion *description.VersionRange) {  argument
440 func (cs *ChangeStream) ID() int64 {  argument
449 func (cs *ChangeStream) Decode(val interface{}) error {  argument
458 func (cs *ChangeStream) Err() error {  argument
471 func (cs *ChangeStream) Close(ctx context.Context) error {  argument
489 func (cs *ChangeStream) ResumeToken() bson.Raw {  argument
500 func (cs *ChangeStream) Next(ctx context.Context) bool {  argument
515 func (cs *ChangeStream) TryNext(ctx context.Context) bool {  argument
519 func (cs *ChangeStream) next(ctx context.Context, nonBlocking bool) bool {  argument
549 func (cs *ChangeStream) loopNext(ctx context.Context, nonBlocking bool) {  argument
590 func (cs *ChangeStream) isResumableError() bool {  argument
612 func (cs *ChangeStream) emptyBatch() bool {  argument