Contents

require 'spec_helper'

describe Listen::Adapter::Polling do
  let(:registry) { double(Celluloid::Registry) }
  let(:listener) { double(Listen::Listener, registry: registry, options: {}, listen?: true) }
  let(:adapter) { described_class.new(listener) }
  let(:change_pool) { double(Listen::Change, terminate: true) }
  let(:change_pool_async) { double('ChangePoolAsync') }
  before {
    change_pool.stub(:async) { change_pool_async }
    registry.stub(:[]).with(:change_pool) { change_pool }
  }

  describe ".usable?" do
    it "returns always true" do
      expect(described_class).to be_usable
    end
  end

  describe "#start" do
    let(:directories) { ['directory_path'] }
    before {
      listener.stub(:options) { {} }
      listener.stub(:directories) { directories }
    }

    it "notifies change on every listener directories path" do
      expect(change_pool_async).to receive(:change).with('directory_path', type: 'Dir', recursive: true)
      t = Thread.new { adapter.start }
      sleep 0.25
      t.kill
    end
  end

  describe "#_latency" do
    it "returns default_latency with listener actor latency not present" do
      expect(adapter.send(:_latency)).to eq Listen::Adapter::Polling::DEFAULT_POLLING_LATENCY
    end

    it "returns latency from listener actor if present" do
      listener.stub(:options) { { latency: 1234 } }
      expect(adapter.send(:_latency)).to eq 1234
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
listen-2.7.4	spec/lib/listen/adapter/polling_spec.rb
listen-2.7.3	spec/lib/listen/adapter/polling_spec.rb
listen-2.7.2	spec/lib/listen/adapter/polling_spec.rb
listen-2.7.1	spec/lib/listen/adapter/polling_spec.rb