Class: Pgbus::Streams::Coalescer::ScheduledTaskScheduler

Inherits:

Object

• Object
• Pgbus::Streams::Coalescer::ScheduledTaskScheduler

Defined in:

lib/pgbus/streams/coalescer.rb

Overview

Default scheduler backed by Concurrent::ScheduledTask. Kept as a tiny adapter so the Coalescer can be unit-tested with a synchronous fake scheduler (no real timers, no sleeps).

Instance Method Summary

• #schedule(delay_seconds) ⇒ Object

Instance Method Details

#schedule(delay_seconds) ⇒ Object

# File 'lib/pgbus/streams/coalescer.rb', line 82

def schedule(delay_seconds, &)
  Concurrent::ScheduledTask.execute(delay_seconds, &)
end