Contents

require 'spec_helper'

describe Typhoeus::Pool do
  let(:easy) { Ethon::Easy.new }
  after { Typhoeus::Pool.clear }

  describe "#easies" do
    it "returns array" do
      expect(Typhoeus::Pool.send(:easies)).to be_a(Array)
    end
  end

  describe "#release" do
    it "resets easy" do
      easy.should_receive(:reset)
      Typhoeus::Pool.release(easy)
    end

    it "puts easy back into pool" do
      Typhoeus::Pool.release(easy)
      expect(Typhoeus::Pool.send(:easies)).to include(easy)
    end

    context "when threaded access" do
      it "releases correct number of easies" do
        (0..9).map do |n|
          Thread.new do
            Typhoeus::Pool.release(Ethon::Easy.new)
          end
        end.map(&:join)
        expect(Typhoeus::Pool.send(:easies)).to have(10).easies
      end
    end
  end

  describe "#get" do
    context "when easy in pool" do
      before { Typhoeus::Pool.send(:easies) << easy }

      it "takes" do
        expect(Typhoeus::Pool.get).to eq(easy)
      end
    end

    context "when no easy in pool" do
      it "creates" do
        expect(Typhoeus::Pool.get).to be_a(Ethon::Easy)
      end

      context "when threaded access" do
        it "creates correct number of easies" do
          array = []
          (0..9).map do |n|
            Thread.new do
              array << Typhoeus::Pool.get
            end
          end.map(&:join)
          expect(array.uniq).to have(10).easies
        end
      end
    end
  end

  describe "#with" do
    it "is re-entrant" do
      array = []
      Typhoeus::Pool.with_easy do |e1|
        array << e1
        Typhoeus::Pool.with_easy do |e2|
          array << e2
          Typhoeus::Pool.with_easy do |e3|
            array << e3
          end
        end
      end
      expect(array.uniq).to have(3).easies
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
typhoeus-0.6.8	spec/typhoeus/pool_spec.rb
typhoeus-0.6.7	spec/typhoeus/pool_spec.rb
typhoeus-0.6.6	spec/typhoeus/pool_spec.rb
typhoeus-0.6.5	spec/typhoeus/pool_spec.rb
typhoeus-0.6.4	spec/typhoeus/pool_spec.rb