Contents

# frozen_string_literal: true

module Bolt
  class Notifier
    def initialize(executor = nil)
      # lazy-load expensive gem code
      require 'concurrent'

      @executor = executor || Concurrent::SingleThreadExecutor.new
    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

5 entries across 5 versions & 1 rubygems

Version	Path
bolt-1.19.0	lib/bolt/notifier.rb
bolt-1.18.0	lib/bolt/notifier.rb
bolt-1.17.0	lib/bolt/notifier.rb
bolt-1.16.0	lib/bolt/notifier.rb
bolt-1.15.0	lib/bolt/notifier.rb