# File lib/mongo/collection/view/change_stream.rb, line 86 def initialize(view, pipeline, changes_for, options = {}) @view = view @changes_for = changes_for @change_stream_filters = pipeline && pipeline.dup @options = options && options.dup.freeze @resume_token = @options[:resume_after] create_cursor! # We send different parameters when we resume a change stream # compared to when we send the first query @resuming = true end