Class: Datapipes::Pipe

Inherits:

Object

• Object
• Datapipes::Pipe

Defined in:

lib/datapipes/pipe.rb

Instance Method Summary

• #empty? ⇒ Boolean
• #initialize ⇒ Pipe constructor

  A new instance of Pipe.

• #pull ⇒ Object
• #recieve(data) ⇒ Object
• #size ⇒ Object

Constructor Details

#initialize ⇒ Pipe

Returns a new instance of Pipe.

# File 'lib/datapipes/pipe.rb', line 3

def initialize
  @queue ||= Queue.new
end

Instance Method Details

#empty? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/datapipes/pipe.rb', line 15

def empty?
  @queue.empty?
end

#pull ⇒ Object

# File 'lib/datapipes/pipe.rb', line 11

def pull
  @queue.deq
end

#recieve(data) ⇒ Object

# File 'lib/datapipes/pipe.rb', line 7

def recieve(data)
  @queue.enq data
end

#size ⇒ Object

# File 'lib/datapipes/pipe.rb', line 19

def size
  @queue.size
end