Contents

require 'aggro/nanomsg_transport/connection'

module Aggro
  module NanomsgTransport
    # Private: Wrapper for a nanomsg XREP node.
    class RawReply < Connection
      def allocate_socket
        @socket = NNCore::LibNanomsg.nn_socket(NNCore::AF_SP_RAW,
                                               NNCore::NN_REP)
        assert @socket
      end

      def set_endpoint
        assert NNCore::LibNanomsg.nn_bind(@socket, @endpoint)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
aggro-0.0.3	lib/aggro/nanomsg_transport/raw_reply.rb
aggro-0.0.2	lib/aggro/nanomsg_transport/raw_reply.rb