Sha256: c1528049f122d343708b62ea01e5443f2e64fc23e8dbd70711ead2b4c7d87a84

Contents?: true

Size: 499 Bytes

Versions: 33

Compression:

Stored size: 499 Bytes

Contents

module Pacer
  module Routes
    module RouteOperations
      def counted
        chain_route :side_effect => :counted
      end

      def count
        counted.count
      end
      alias run! count
    end
  end


  module SideEffect
    module Counted
      def count
        cap.first
      end

      protected

      def attach_pipe(end_pipe)
        @pipe = com.tinkerpop.pipes.sideeffect.CountPipe.new
        @pipe.setStarts(end_pipe) if end_pipe
        @pipe
      end
    end
  end
end

Version data entries

33 entries across 33 versions & 1 rubygems

Version Path
pacer-2.0.24-java lib/pacer/side_effect/counted.rb
pacer-2.0.22-java lib/pacer/side_effect/counted.rb
pacer-2.0.20-java lib/pacer/side_effect/counted.rb
pacer-2.0.19-java lib/pacer/side_effect/counted.rb
pacer-2.0.18-java lib/pacer/side_effect/counted.rb
pacer-2.0.17-java lib/pacer/side_effect/counted.rb
pacer-2.0.16-java lib/pacer/side_effect/counted.rb
pacer-2.0.15-java lib/pacer/side_effect/counted.rb
pacer-2.0.14-java lib/pacer/side_effect/counted.rb
pacer-2.0.13-java lib/pacer/side_effect/counted.rb
pacer-2.0.12-java lib/pacer/side_effect/counted.rb
pacer-2.0.10-java lib/pacer/side_effect/counted.rb
pacer-2.0.10.pre-java lib/pacer/side_effect/counted.rb
pacer-2.0.8-java lib/pacer/side_effect/counted.rb
pacer-2.0.6-java lib/pacer/side_effect/counted.rb
pacer-2.0.4.pre-java lib/pacer/side_effect/counted.rb
pacer-2.0.0.pre-java lib/pacer/side_effect/counted.rb
pacer-1.6.0-java lib/pacer/side_effect/counted.rb
pacer-1.5.4-java lib/pacer/side_effect/counted.rb
pacer-1.5.3-java lib/pacer/side_effect/counted.rb