Sha256: 4e7f8def063bbc18dceee1db6362f89f4ac2924e20a0d6f5931d7b25bf86ad16
Contents?: true
Size: 419 Bytes
Versions: 27
Compression:
Stored size: 419 Bytes
Contents
module Pacer
module Routes::RouteOperations
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
27 entries across 27 versions & 1 rubygems