Sha256: e4b431c9f770e27c791cd83acbcf75dc7e9c8a1daf454209d3fed89481d8387a
Contents?: true
Size: 919 Bytes
Versions: 21
Compression:
Stored size: 919 Bytes
Contents
# frozen_string_literal: true
module PubSubModelSync
class MockGoogleService
class MockStop
def wait!
true
end
end
class MockSubscriber
def start
true
end
def stop
@stop ||= MockStop.new
end
alias stop! stop
end
class MockSubscription
def listen(*_args)
@listen ||= MockSubscriber.new
end
end
class MockTopic
def name
'name'
end
def subscription(*_args)
@subscription ||= MockSubscription.new
end
alias subscribe subscription
def publish(*_args)
true
end
def publish_async(*_args)
yield(OpenStruct.new(succeeded?: true)) if block_given?
end
def enable_message_ordering!
true
end
end
def topic(*_args)
@topic ||= MockTopic.new
end
alias create_topic topic
end
end
Version data entries
21 entries across 21 versions & 1 rubygems