Sha256: 593328deb3a28f98aaa8e7648e28a80c5aa7ea1d57c55cd17701166c3ad0f054
Contents?: true
Size: 459 Bytes
Versions: 27
Compression:
Stored size: 459 Bytes
Contents
module Pacer
module Routes::RouteOperations
def stream_sort(buffer = 1000, silo = 100)
chain_route :transform => :stream_sort, :buffer => buffer, :silo => silo
end
end
module Transform
module StreamSort
attr_accessor :buffer, :silo
protected
def attach_pipe(end_pipe)
pipe = Pacer::Pipes::StreamSortPipe.new buffer, silo
pipe.setStarts end_pipe if end_pipe
pipe
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems