Contents

module Pacer
  module Routes::RouteOperations
    # Deprecated: use uniq_section instead.
    def stream_uniq(buffer = 1000)
      chain_route :transform => :stream_uniq, :buffer => buffer
    end
  end

  module Transform
    module StreamUniq
      attr_accessor :buffer

      protected

      def attach_pipe(end_pipe)
        pipe = Pacer::Pipes::StreamUniqPipe.new buffer
        pipe.setStarts end_pipe if end_pipe
        pipe
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
pacer-2.0.24-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.22-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.20-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.19-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.18-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.17-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.16-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.15-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.14-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.13-java	lib/pacer/transform/stream_uniq.rb
pacer-2.0.12-java	lib/pacer/transform/stream_uniq.rb