Module: Puma::QueueClose

Defined in:
lib/puma/queue_close.rb

Overview

Queue#close was added in Ruby 2.3. Add a simple implementation for earlier Ruby versions.

Instance Method Summary collapse

Instance Method Details

#closeObject



12
13
14
# File 'lib/puma/queue_close.rb', line 12

def close
  @closed = true
end

#closed?Boolean

Returns:

  • (Boolean)


15
16
17
# File 'lib/puma/queue_close.rb', line 15

def closed?
  @closed
end

#initializeObject



8
9
10
11
# File 'lib/puma/queue_close.rb', line 8

def initialize
  @closed = false
  super
end

#push(object) ⇒ Object Also known as: <<

Raises:



18
19
20
21
22
# File 'lib/puma/queue_close.rb', line 18

def push(object)
  @closed ||= false
  raise ClosedQueueError if @closed
  super
end