Contents

module Pacer::Pipes
  class CrossProductTransformPipe < UnaryTransformPipe
    attr_reader :branch_b

    def initialize(method, branch_a, branch_b)
      super(method, branch_a)
      if branch_b.is_a? Pipe
        @branch_b = branch_b
        @b = nil
      else
        @b = branch_b
      end
    end

    def processNextStart
      next_pair
      a.send method, b rescue nil if a.respond_to? method
    rescue NativeException => e
      if e.cause.getClass == Pacer::NoSuchElementException.getClass
        raise e.cause
      else
        raise e
      end
    end

    protected

    attr_accessor :b

    def next_pair
      if branch_b
        begin
          self.b = branch_b.next
        rescue NativeException => e
          if e.cause.getClass == Pacer::NoSuchElementException.getClass or @first
            next_a
            branch_b.setStarts SingleIterator.new(element)
            retry
          else
            raise e
          end
        end
      else
        next_a
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pacer-0.9.1.1-java	lib/pacer/pipe/cross_product_transform_pipe.rb