Sha256: 00fcc59b13377f3a472ebd9c4acceee6feb61f64d166523afba30a7d4f7cc492

Contents?: true

Size: 819 Bytes

Versions: 4

Compression:

Stored size: 819 Bytes

Contents

require 'spec_helper'

describe "NIO acceptables" do
  shared_context "an NIO acceptable" do
    let(:selector) { NIO::Selector.new }

    it "selects for read readiness" do
      waiting_monitor = selector.register(unacceptable_subject, :r)
      ready_monitor   = selector.register(acceptable_subject, :r)

      ready_monitors = selector.select
      expect(ready_monitors).to include ready_monitor
      expect(ready_monitors).not_to include waiting_monitor
    end
  end

  describe TCPServer do
    let(:tcp_port) { 23456 }

    let :acceptable_subject do
      server = TCPServer.new("localhost", tcp_port)
      TCPSocket.open("localhost", tcp_port)
      server
    end

    let :unacceptable_subject do
      TCPServer.new("localhost", tcp_port + 1)
    end

    it_behaves_like "an NIO acceptable"
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
nio4r-1.1.0 spec/nio/acceptables_spec.rb
nio4r-1.1.0-java spec/nio/acceptables_spec.rb
nio4r-1.0.1-java spec/nio/acceptables_spec.rb
nio4r-1.0.1 spec/nio/acceptables_spec.rb