Sha256: 1d5dcfa0dd0833a3bae521ba2ebfae2236564b194e051308a48ccb26dc17146e
Contents?: true
Size: 269 Bytes
Versions: 7
Compression:
Stored size: 269 Bytes
Contents
class Datapipes class Pipe def initialize @queue ||= Queue.new end def recieve(data) @queue.enq data end def pull @queue.deq end def empty? @queue.empty? end def size @queue.size end end end
Version data entries
7 entries across 7 versions & 1 rubygems