Contents

# frozen_string_literal: true

module Polyphony
  # Event watcher for thread-safe synchronisation
  class Event
    def await
      @fiber = Fiber.current
      Thread.current.agent.wait_event(true)
    end

    def signal(value = nil)
      @fiber&.schedule(value)
    ensure
      @fiber = nil
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
polyphony-0.43.8	lib/polyphony/event.rb