Module: Aggro::NanomsgTransport

Defined in:
lib/aggro/nanomsg_transport.rb

Overview

Public: Transport layer over nanomsg sockets.

Class Method Summary collapse

Class Method Details

.client(endpoint) ⇒ Object 



11
12
13
 
# File 'lib/aggro/nanomsg_transport.rb', line 11

def client(endpoint)
  Client.new endpoint
end

.publisher(endpoint) ⇒ Object 



15
16
17
 
# File 'lib/aggro/nanomsg_transport.rb', line 15

def publisher(endpoint)
  Publisher.new endpoint
end

.server(endpoint, callable = nil, &block) ⇒ Object 



19
20
21
 
# File 'lib/aggro/nanomsg_transport.rb', line 19

def server(endpoint, callable = nil, &block)
  Server.new endpoint, callable, &block
end

.subscriber(endpoint, callable = nil, &block) ⇒ Object 



23
24
25
 
# File 'lib/aggro/nanomsg_transport.rb', line 23

def subscriber(endpoint, callable = nil, &block)
  Subscriber.new endpoint, callable, &block
end

.teardown ⇒ Object 



27
28
29
 
# File 'lib/aggro/nanomsg_transport.rb', line 27

def teardown
  NNCore::LibNanomsg.nn_term
end