Sha256: ae0a6c6e3f98f27946c316aac20de05ce3c140b32023ccd4dd07084a4700a75e
Contents?: true
Size: 967 Bytes
Versions: 13
Compression:
Stored size: 967 Bytes
Contents
# frozen_string_literal: true
require 'spec_helper'
describe RubyRabbitmqJanus::Process::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::Process::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::Process::Concurrencies::KeepaliveTimer) }
it { expect(concurrency.instance_variable_get(:@message)).to be_a(RubyRabbitmqJanus::Process::Concurrencies::KeepaliveMessage) }
end
Version data entries
13 entries across 13 versions & 1 rubygems