Sha256: 4d8628ae080997878cf050b35f343ef07f3d405d9a6ed603d5a797966033f14c
Contents?: true
Size: 1.48 KB
Versions: 12
Compression:
Stored size: 1.48 KB
Contents
require 'spec_helper'
describe Listen do
let(:listener) { instance_double(Listen::Listener, stop: nil) }
after do
Listen.stop
end
describe '.to' do
it 'initalizes listener' do
expect(Listen::Listener).to receive(:new).with('/path') { listener }
described_class.to('/path')
end
context 'when using :forward_to option' do
it 'initializes TCP-listener in broadcast-mode' do
expect(Listen::Listener).to receive(:new).
with(4000, :broadcaster, '/path', {}) { listener }
described_class.to('/path', forward_to: 4000)
end
end
end
describe '.stop' do
it 'stops all listeners & Celluloid' do
allow(Listen::Listener).to receive(:new).with('/path') { listener }
expect(listener).to receive(:stop)
described_class.to('/path')
Listen.stop
# TODO: running? returns internal_pool on 0.15.2
# (remove after Celluloid dependency is bumped)
buggy_method = if Celluloid.respond_to?(:internal_pool)
Celluloid.running? == Celluloid.internal_pool
else
false
end
pool = buggy_method ? Celluloid.internal_pool : Celluloid
expect(pool).to_not be_running
end
end
describe '.on' do
it 'initializes TCP-listener in recipient-mode' do
expect(Listen::Listener).to receive(:new).
with(4000, :recipient, '/path') { listener }
described_class.on(4000, '/path')
end
end
end
Version data entries
12 entries across 10 versions & 3 rubygems