start(name, id, payload) Instance Public methods

subscribe(pattern = nil, block = Proc.new) Instance Public methods

unsubscribe(subscriber) Instance Public methods

wait() Instance Public methods This is a sync queue, so there is no waiting.

new(notifier) Class Public methods

finish(name, payload) Instance Public methods Send a finish notification with name and payload.

instrument(name, payload={}) Instance Public methods Instrument the given block by measuring the time taken to execute it and publish it. Notice that events get sent even if an error occurs in the passed-in block.

start(name, payload) Instance Public methods Send a start notification with name and payload.

instrument(name, payload = {}) Class Public methods

instrumenter() Class Public methods