Sha256: 3f7a3e0e272425323180ad972c871b290f464e2c79a976aaec3384bf1e78e32d
Contents?: true
Size: 617 Bytes
Versions: 7
Compression:
Stored size: 617 Bytes
Contents
module Connfu
##
# This class is used to send Message instances between transport (listener) and dispatcher layers
class Events
##
# Initializer
def initialize
@queue = Queue.new
end
##
# Returns a message from the queue. It waits until there's at least one message in the queue and acts
# as a FIFO queue.
#
# ==== Returns
# Connfu::Message instance
def get
@queue.pop
end
##
# Inserts a message in the queue
#
# ==== Parameters
# * +event+ Connfu::Message instance
def put(event)
@queue << event
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems