Module: Wurk::API::Fast::SortedSetExt

Included in:
SortedSet
Defined in:
lib/wurk/api/fast.rb

Overview

Extension to Wurk::SortedSet / JobSet. The base ‘scan(match, count)` already yields `(value, score)` pairs via ZSCAN — Pro promotes the surface to yield `JobRecord` directly so callers can `entry.delete` / `entry.retry` without re-parsing JSON.

The new behavior is enabled by *block arity*: a 1-arg block (or block.lambda? + a 1-param signature) receives ‘JobRecord`; legacy 2-arg blocks (`|value, score|`) keep the raw shape. This preserves the existing two-arg contract used by JobSet#find_job internally.

Instance Method Summary collapse

Instance Method Details

#scan(match, count = 100, &block) ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/wurk/api/fast.rb', line 61

def scan(match, count = 100, &block)
  return enum_for(:scan, match, count) unless block

  if block.arity == 1
    super do |value, score|
      block.call(Wurk::SortedEntry.new(self, score, value))
    end
  else
    super
  end
end