Contents

# frozen_string_literal: true

require 'concurrent'

module Bolt
  class Notifier
    def initialize(executor = Concurrent::SingleThreadExecutor.new)
      @executor = executor
    end

    def notify(callback, event)
      @executor.post do
        callback.call(event)
      end
    end

    def shutdown
      @executor.shutdown
      @executor.wait_for_termination
    end
  end
end

Version data entries

41 entries across 41 versions & 1 rubygems

Version	Path
bolt-0.18.0	lib/bolt/notifier.rb