Sha256: 88a7b33955496e19bd437225874cdaaae2243279e3270243ed7f41055832f76d
Contents?: true
Size: 672 Bytes
Versions: 8
Compression:
Stored size: 672 Bytes
Contents
require_relative 'socket'
# Syntactic sugar for 0MQ, because Ruby shouldn't feel like C.
module EZMQ
# Pull socket that receives messages but does not send them. Pullers can
# connect to multiple Pushers, and will fair-queue messages from available
# sources.
class Puller < EZMQ::Socket
# Creates a new Puller socket.
#
# @param [:bind, :connect] mode a mode for the socket.
# @param [Hash] options optional parameters.
# @see EZMQ::Socket EZMQ::Socket for optional parameters.
#
# @return [Puller] a new instance of Puller.
#
def initialize(mode = :bind, **options)
super mode, ZMQ::PULL, options
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems