module Aggro::NanomsgTransport
Public: Transport layer over nanomsg sockets.
Public Instance Methods
client(endpoint)
click to toggle source
# File lib/aggro/nanomsg_transport.rb, line 11 def client(endpoint) Client.new endpoint end
publisher(endpoint)
click to toggle source
# File lib/aggro/nanomsg_transport.rb, line 15 def publisher(endpoint) Publisher.new endpoint end
server(endpoint, callable = nil, &block)
click to toggle source
# 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)
click to toggle source
# File lib/aggro/nanomsg_transport.rb, line 23 def subscriber(endpoint, callable = nil, &block) Subscriber.new endpoint, callable, &block end
teardown()
click to toggle source
# File lib/aggro/nanomsg_transport.rb, line 27 def teardown NNCore::LibNanomsg.nn_term end