Class: Pacer::Pipes::BloomFilter::SideliningPipe

Inherits:
AbstractPipe
  • Object
show all
Defined in:
lib/pacer/pipe/bloomfilter_reject.rb

Direct Known Subclasses

RejectPipe, SelectPipe

Instance Method Summary collapse

Constructor Details

#initialize(pipe) ⇒ SideliningPipe

Returns a new instance of SideliningPipe.



5
6
7
8
9
10
11
12
 
# File 'lib/pacer/pipe/bloomfilter_reject.rb', line 5

def initialize(pipe)
  super()
  if pipe
    @sideline = pipe
    @sidelineExpando = ExpandableIterator.new(java.util.ArrayList.new.iterator);
    @sideline.setStarts(@sidelineExpando);
  end
end