Sha256: 05d4e783caa95c7458909dd9ee513a04033f5aaf1fdff073522d7969a9e2eae6
Contents?: true
Size: 739 Bytes
Versions: 14
Compression:
Stored size: 739 Bytes
Contents
# frozen_string_literal: true
require 'spec_helper'
describe RubyRabbitmqJanus::Janus::Concurrencies::KeepaliveThread, type: :thread, name: :keepalive_initializer do
let(:instance) { RubyRabbitmqJanus::Models::JanusInstance.find((ENV['MONGO'].match?('true') ? %w[1 2] : [1, 2]).sample) }
let(:concurrency) { RubyRabbitmqJanus::Janus::Concurrencies::KeepaliveInitializer.new(instance) }
it { expect(concurrency.send(:rabbit)).to be_a(RubyRabbitmqJanus::Rabbit::Connect) }
it { expect(concurrency.send(:lock)).to be_a(Mutex) }
it { expect(concurrency.send(:condition)).to be_a(ConditionVariable) }
it { expect(concurrency.instance_variable_get(:@thread)).to be_a(RubyRabbitmqJanus::Janus::Concurrencies::KeepaliveThread) }
end
Version data entries
14 entries across 14 versions & 1 rubygems