subscribe(*args, &block) Class Public methods

publish(name, *args) Class Public methods

instrumenter() Class Public methods

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

start(name, payload) Instance Public methods Send a start 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.

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

new(notifier) Class Public methods

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

unsubscribe(subscriber) Instance Public methods