Class: Airflow::SigHandler

Inherits:

Object

• Object
• Airflow::SigHandler

Includes:

Utils::Logger

Defined in:

lib/async_flow/sig_handler.rb

Constant Summary

SIGNAL_HANDLERS =

{
  "INT" => ->(_subject) { raise Interrupt },
  "TERM" => ->(_subject) { raise Interrupt }
}.freeze

Instance Method Summary

• #call ⇒ Object
• #initialize(subject) ⇒ SigHandler constructor

  A new instance of SigHandler.

Methods included from Utils::Logger

#logger

Constructor Details

#initialize(subject) ⇒ SigHandler

Returns a new instance of SigHandler.

# File 'lib/async_flow/sig_handler.rb', line 12

def initialize(subject)
  @subject = subject
  @read_io, @write_io = IO.pipe
end

Instance Method Details

#call ⇒ Object

# File 'lib/async_flow/sig_handler.rb', line 17

def call
  trap
  yield
  wait
end