class Async::IO::Notification

A cross-reactor/process notification pipe.

def close 

def close
	@input.close
	@output.close
end

def initialize 

def initialize
	pipe = ::IO.pipe
	
	@input = pipe.first
	@output = pipe.last
end

def signal

Returns:
  • (void) - 
def signal
	@output.write(".")
end

def wait

Returns:
  • (Object) - 
def wait
	wrapper = Async::IO::Generic.new(@input)
	wrapper.read(1)
end