Class: Async::Container::Notify::Server::Context

Inherits:
Object
  • Object
show all
Defined in:
lib/async/container/notify/server.rb

Instance Method Summary collapse

Constructor Details

#initialize(path) ⇒ Context

Returns a new instance of Context.



63
64
65
66
67
68
69
70
71
72
 
# File 'lib/async/container/notify/server.rb', line 63

def initialize(path)
	@path = path
	@endpoint = IO::Endpoint.unix(@path, ::Socket::SOCK_DGRAM)
	
	Sync do
		@bound = @endpoint.bind
	end
	
	@state = {}
end

Instance Method Details

#close ⇒ Object 



74
75
76
77
78
79
80
 
# File 'lib/async/container/notify/server.rb', line 74

def close
	Sync do
		@bound.close
	end
	
	File.unlink(@path)
end

#receive ⇒ Object 



82
83
84
85
86
87
88
89
90
 
# File 'lib/async/container/notify/server.rb', line 82

def receive
	while true
		data, _address, _flags, *_controls = @bound.recvmsg(MAXIMUM_MESSAGE_SIZE)
		
		message = Server.load(data)
		
		yield message
	end
end