class Aggregate

def call(job)

Enqueue a job into the pending buffer.

Start the background processing task if it is not already running.

def call(job)
	@pending << job
	
	start! or @ready.signal
end