Contents

module ZMQ
  if LibZMQ.version2?
    class Device
      attr_reader :device
      
      def self.create(device_type, frontend, backend)
        dev = nil
        begin
          dev = new device_type, frontend, backend
        rescue ArgumentError
          dev = nil
        end
        
        dev
      end

      def initialize(device_type,frontend,backend)
        [["frontend", frontend],["backend", backend]].each do |name,socket|
          unless socket.is_a?(ZMQ::Socket)
            raise ArgumentError, "Expected a ZMQ::Socket, not a #{socket.class} as the #{name}"
          end
        end

        LibZMQ.zmq_device(device_type, frontend.socket, backend.socket)
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
ffi-rxs-1.1.0	lib/ffi-rxs/device.rb~
ffi-rxs-1.0.1	lib/ffi-rxs/device.rb~
ffi-rxs-1.0.0	lib/ffi-rxs/device.rb~
ffi-rzmq-0.9.3	lib/ffi-rzmq/device.rb
ffi-rzmq-0.9.2	lib/ffi-rzmq/device.rb
ffi-rzmq-0.9.0	lib/ffi-rzmq/device.rb