module Mongo::Collection::View::ChangeStream::Retryable

Behavior around resuming a change stream.

@since 2.5.0

Private Instance Methods

read_with_one_retry() { || ... } click to toggle source
# File lib/mongo/collection/view/change_stream/retryable.rb, line 27
def read_with_one_retry
  yield
rescue Mongo::Error => e
  if e.change_stream_resumable?
    yield
  else
    raise(e)
  end
end