Sha256: 8070eedae8b2d482aed0f2fd6b1fd3316bfbbdc5797bcd89490903846a8345c3

Contents?: true

Size: 858 Bytes

Versions: 6

Compression:

Stored size: 858 Bytes

Contents

# frozen_string_literal: true

require "spec_helper"

RSpec.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(:port) { next_available_tcp_port }

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

    let :unacceptable_subject do
      TCPServer.new("127.0.0.1", port + 1)
    end

    it_behaves_like "an NIO acceptable"
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
nio4r-2.3.1-java spec/nio/acceptables_spec.rb
nio4r-2.3.1 spec/nio/acceptables_spec.rb
nio4r-2.3.0-java spec/nio/acceptables_spec.rb
nio4r-2.3.0 spec/nio/acceptables_spec.rb
nio4r-2.2.0-java spec/nio/acceptables_spec.rb
nio4r-2.2.0 spec/nio/acceptables_spec.rb