ipc.rb

#!/usr/bin/env ruby

require 'async'
require 'async/io/unix_endpoint'

endpoint = Async::IO::Endpoint.unix("foo.ipc")

fork do
	Async do
		endpoint.accept do |peer|
			Console.logger.info(peer, "sleep 1")
			Async::Task.current.sleep(1)
			Console.logger.info(peer, "sepukku")
			Process.kill(:KILL, Process.pid)
		end
	end
end

sleep 1

Async do
	endpoint.connect do |peer|
		Console.logger.info(peer, "read")
		puts peer.read.inspect
	rescue
		Console.logger.error(peer, $!)
	end
end