Module: StreamWrapper

Defined in:
lib/logbox/stream_wrapper.rb,
lib/logbox/stream_wrapper/gzip_multi_file.rb,
lib/logbox/stream_wrapper/observation_filter.rb,
lib/logbox/stream_wrapper/order_blob_splitter.rb

Defined Under Namespace

Classes: GzipMultiFile, ObservationFilter, OrderBlobSplitter

Class Method Summary collapse

Class Method Details

.open(paths = [], filters = nil) ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/logbox/stream_wrapper.rb', line 10

def open(paths = [], filters = nil)
  if filters
    ObservationFilter.new(OrderBlobSplitter.new(GzipMultiFile.new(paths, filters)), filters)
  else
    OrderBlobSplitter.new(GzipMultiFile.new(paths))
  end
end