Class: Async::Bus::Server

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

Overview

Represents a server that accepts async-bus connections.

Instance Method Summary collapse

Constructor Details

#initialize(endpoint = nil, **options) ⇒ Server

Initialize a new server.



18
19
20
21
 
# File 'lib/async/bus/server.rb', line 18

def initialize(endpoint = nil, **options)
	@endpoint = endpoint || Protocol.local_endpoint
	@options = options
end

Instance Method Details

#accept(&block) ⇒ Object

Accept incoming connections.



33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/async/bus/server.rb', line 33

def accept(&block)
	@endpoint.accept do |peer|
		connection = Protocol::Connection.server(peer, **@options)
		
		connected!(connection, &block)
		
		yield connection if block_given?
		
		connection.run
	ensure
		connection&.close
	end
end