Sha256: 109ed14fe030a7b93d52524f0e40ec5f1cb58acb67dc559ddb507628b3292879

Contents?: true

Size: 731 Bytes

Versions: 28

Compression:

Stored size: 731 Bytes

Contents

# encoding: utf-8

class ZMQ::Socket::Pull

# == ZMQ::Socket::Pull
#
# A socket of type ZMQ::Socket::Pull is used by a pipeline node to receive messages from upstream pipeline nodes. Messages
# are fair-queued from among all connected upstream nodes. The ZMQ::Socket#send function is not implemented for this
# socket type.
#
# Deprecated alias: ZMQ_UPSTREAM.
#
# === Summary of ZMQ::Socket::Pull characteristics
#
# [Compatible peer sockets] ZMQ::Socket::Push
# [Direction] Unidirectional
# [Send/receive pattern] Receive only
# [Incoming routing strategy] Fair-queued
# [Outgoing routing strategy] N/A
# [ZMQ::Socket#hwm option action] N/A

  TYPE_STR = "PULL"

  def type
    ZMQ::PULL
  end

  include ZMQ::DownstreamSocket
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version Path
rbczmq-1.7.9 lib/zmq/socket/pull.rb
rbczmq-1.7.8 lib/zmq/socket/pull.rb
rbczmq-1.7.7 lib/zmq/socket/pull.rb
rbczmq-1.7.6 lib/zmq/socket/pull.rb
rbczmq-1.7.5 lib/zmq/socket/pull.rb
rbczmq-1.7.4 lib/zmq/socket/pull.rb
rbczmq-1.7.3 lib/zmq/socket/pull.rb
rbczmq-1.7.2 lib/zmq/socket/pull.rb
rbczmq-1.7.1 lib/zmq/socket/pull.rb
rbczmq-1.7.0 lib/zmq/socket/pull.rb
rbczmq-1.6.4 lib/zmq/socket/pull.rb
rbczmq-1.6.2 lib/zmq/socket/pull.rb
rbczmq-1.6 lib/zmq/socket/pull.rb
rbczmq-1.5 lib/zmq/socket/pull.rb
rbczmq-1.4 lib/zmq/socket/pull.rb
rbczmq-1.3 lib/zmq/socket/pull.rb
rbczmq-1.2 lib/zmq/socket/pull.rb
rbczmq-1.1 lib/zmq/socket/pull.rb
rbczmq-1.0 lib/zmq/socket/pull.rb
rbczmq-0.9 lib/zmq/socket/pull.rb