Skip to content
Newer
Older
100644 22 lines (18 sloc) 419 Bytes
27fa37f Added stream_uniq with a simple implementation.
Darrick Wiebe authored
1 module Pacer
2 module Routes::RouteOperations
3 def stream_uniq(buffer = 1000)
4 chain_route :transform => :stream_uniq, :buffer => buffer
5 end
6 end
7
8 module Transform
9 module StreamUniq
10 attr_accessor :buffer
11
12 protected
13
14 def attach_pipe(end_pipe)
15 pipe = Pacer::Pipes::StreamUniqPipe.new buffer
ebcc977 It only makes sense to call setStarts if the pipe is non-nil.
Darrick Wiebe authored
16 pipe.setStarts end_pipe if end_pipe
27fa37f Added stream_uniq with a simple implementation.
Darrick Wiebe authored
17 pipe
18 end
19 end
20 end
21 end
Something went wrong with that request. Please try again.