Sha256: 0e8b879130233bdb068816016ae80d04b8dc52422c492b7bde6f4debce05eaa8

Contents?: true

Size: 476 Bytes

Versions: 5

Compression:

Stored size: 476 Bytes

Contents

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

      def count
        counted.count
      end
    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

5 entries across 5 versions & 1 rubygems

Version Path
pacer-1.0.3-java lib/pacer/side_effect/counted.rb
pacer-1.0.2-java lib/pacer/side_effect/counted.rb
pacer-1.0.1-java lib/pacer/side_effect/counted.rb
pacer-1.0.0-java lib/pacer/side_effect/counted.rb
pacer-0.9.1.1-java lib/pacer/side_effect/counted.rb