Class: Pacer::Pipes::StreamUniqPipe

Inherits:

RubyPipe

• Object
• AbstractPipe
• RubyPipe
• Pacer::Pipes::StreamUniqPipe

Defined in:

lib/pacer/pipe/stream_uniq_pipe.rb

Instance Attribute Summary

Attributes inherited from RubyPipe

#starts

Instance Method Summary

• #initialize(buffer = 1000) ⇒ StreamUniqPipe constructor

  A new instance of StreamUniqPipe.

Methods inherited from RubyPipe

#enablePath, #reset, #setStarts

Constructor Details

#initialize(buffer = 1000) ⇒ StreamUniqPipe

Returns a new instance of StreamUniqPipe.

# File 'lib/pacer/pipe/stream_uniq_pipe.rb', line 3

def initialize(buffer = 1000)
  super()
  @list = java.util.LinkedList.new
  @buffer = buffer
end