Sha256: f007a32a8f9bd6957e4ad1656669269c28c9adf73e5cc7f4f252584fce920995

Contents?: true

Size: 569 Bytes

Versions: 6

Compression:

Stored size: 569 Bytes

Contents

require_relative 'socket'

# Syntactic sugar for 0MQ, because Ruby shouldn't feel like C.
module EZMQ
  # Push socket that sends messages but does not receive them.
  class Pusher < EZMQ::Socket
    # Creates a new Pusher socket.
    #
    # @param [:bind, :connect] mode a mode for the socket.
    # @param [Hash] options optional parameters.
    # @see EZMQ::Socket EZMQ::Socket for optional parameters.
    #
    # @return [Pusher] a new instance of Pusher.
    #
    def initialize(mode = :connect, **options)
      super mode, ZMQ::PUSH, options
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
ezmq-0.3.6 lib/ezmq/push.rb
ezmq-0.3.5 lib/ezmq/push.rb
ezmq-0.3.4 lib/ezmq/push.rb
ezmq-0.3.3 lib/ezmq/push.rb
ezmq-0.3.2 lib/ezmq/push.rb
ezmq-0.3.1 lib/ezmq/push.rb