Class: Brute::Queue::SequentialQueue

Inherits:

BaseQueue

• Object
• BaseQueue
• Brute::Queue::SequentialQueue

Defined in:

lib/brute/queue/sequential_queue.rb

Overview

A queue that processes steps one at a time, in order. One worker, one concurrency slot.

Instance Attribute Summary

Attributes inherited from BaseQueue

#steps

Instance Method Summary

• #initialize(parent: Async::Task.current) ⇒ SequentialQueue constructor

  A new instance of SequentialQueue.

Methods inherited from BaseQueue

#<<, #cancel, #drain, #first, #last, #start

Constructor Details

#initialize(parent: Async::Task.current) ⇒ SequentialQueue

Returns a new instance of SequentialQueue.

# File 'lib/brute/queue/sequential_queue.rb', line 11

def initialize(parent: Async::Task.current)
  super(concurrency: 1, worker_count: 1, parent: parent)
end