Sha256: a716f9afd7493600243bfe786648ccb951e261f1bf4e7d8e6ebff1a0a0e32af0

Contents?: true

Size: 1.14 KB

Versions: 9

Compression:

Stored size: 1.14 KB

Contents

module Pacer
  module Pipes
    class SimpleVisitorPipe < Pacer::Pipes::RubyPipe
      attr_reader :visitor, :in_section, :wrapper, :graph

      attr_accessor :use_on_element, :use_after_element, :use_reset

      def initialize(wrapper, graph)
        super()
        @in_section = false
        @wrapper = wrapper
        @graph = graph
      end

      def visitor=(visitor)
        @visitor = visitor
        @use_on_element      = visitor.respond_to? :on_element
        @use_after_element   = visitor.respond_to? :after_element
        @use_reset           = visitor.respond_to? :reset
      end

      def processNextStart
        visitor.after_element if use_after_element and in_section
        current = starts.next
        @in_section = true unless in_section
        if use_on_element
          wrapped = wrapper.new graph, current
          visitor.on_element(wrapped)
        end
        return current
      rescue EmptyPipe, java.util.NoSuchElementException
        @in_section = false
        raise EmptyPipe.instance
      end

      def reset
        visitor.reset if use_reset
        @in_section = false
        super
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
pacer-1.3.4-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.3.3-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.3.2-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.3.1-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.2.0-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.1.1-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.1.0-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.0.3-java lib/pacer/pipe/simple_visitor_pipe.rb
pacer-1.0.2-java lib/pacer/pipe/simple_visitor_pipe.rb