Sha256: ade465a3a428e23e7e09f2619d7be2b01a5dc2a0a13c6b55a330841b314394d9
Contents?: true
Size: 959 Bytes
Versions: 23
Compression:
Stored size: 959 Bytes
Contents
# frozen_string_literal: true
require 'spec_helper'
describe RubyRabbitmqJanus::Janus::Concurrencies::KeepaliveThread, type: :thread, name: :keepalive_thread do
let(:instance) { RubyRabbitmqJanus::Models::JanusInstance.find((ENV['MONGO'].match?('true') ? %w[1 2] : [1, 2]).sample) }
let(:rabbit) { RubyRabbitmqJanus::Janus::Concurrencies::Concurrency.new.send(:rabbit) }
let(:concurrency) { described_class.new(instance, rabbit) { nil } }
it { expect(concurrency.instance_variable_get(:@session)).to be(nil) }
it { expect(concurrency.instance_variable_get(:@publisher)).to be(nil) }
it { expect(concurrency.instance_variable_get(:@rabbit)).to be_a(RubyRabbitmqJanus::Rabbit::Connect) }
it { expect(concurrency.instance_variable_get(:@timer)).to be_a(RubyRabbitmqJanus::Janus::Concurrencies::KeepaliveTimer) }
it { expect(concurrency.instance_variable_get(:@message)).to be_a(RubyRabbitmqJanus::Janus::Concurrencies::KeepaliveMessage) }
end
Version data entries
23 entries across 23 versions & 1 rubygems