Contents

$: << File.dirname(__FILE__)
require "stream_wrapper/gzip_multi_file"
require "stream_wrapper/observation_filter"
require "stream_wrapper/order_blob_splitter"

module StreamWrapper

  class << self

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logbox-0.2.10	lib/logbox/stream_wrapper.rb