class Backports::Ractor::OutgoingQueue
-
Wraps exception
-
Add ‘ack: ` to push (blocking)
Constants
- TYPE
- WrappedException
Public Class Methods
Source
# File lib/backports/ractor/queues.rb, line 34 def initialize @ack_queue = ::Queue.new super end
Calls superclass method
Backports::FilteredQueue::new
Public Instance Methods
Source
# File lib/backports/ractor/queues.rb, line 47 def close(how = :hard) super() return if how == :soft clear @ack_queue.close end
Calls superclass method
Backports::FilteredQueue#close
Source
# File lib/backports/ractor/queues.rb, line 39 def pop(timeout: nil, ack: true) r = super(timeout: timeout) @ack_queue << :done if ack raise r.exception if WrappedException === r r end
Calls superclass method
Backports::FilteredQueue#pop
Source
# File lib/backports/ractor/queues.rb, line 55 def push(obj, ack:) super(obj) if ack r = @ack_queue.pop # block until popped raise ClosedError, "The #{self.class::TYPE}-port is already closed" unless r == :done end self end
Calls superclass method
Backports::FilteredQueue#push