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

Version Path
datapipes-0.1.2 lib/datapipes/pipe.rb
datapipes-0.1.1 lib/datapipes/pipe.rb
datapipes-0.1.0 lib/datapipes/pipe.rb
datapipes-0.0.4 lib/datapipes/pipe.rb
datapipes-0.0.3 lib/datapipes/pipe.rb
datapipes-0.0.2 lib/datapipes/pipe.rb
datapipes-0.0.1 lib/datapipes/pipe.rb