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