lib/rio/stream.rb in rio-0.3.4 vs lib/rio/stream.rb in rio-0.3.6

- old
+ new

@@ -41,10 +41,11 @@ require 'rio/ops/stream/input' require 'rio/ops/stream/output' require 'rio/ext' require 'rio/filter/gzip' +#require 'rio/filter/yaml' #require 'rio/filter/chomp' #require 'rio/filter/strip' require 'rio/filter/closeoneof' module RIO @@ -114,14 +115,16 @@ super self.ioh.oncloseproc = proc { self.on_closeoneof } if closeoneof? end def add_extensions() + #p callstr('add_extensions') Ext::Input.add_extensions(self) end def add_filters add_filter(Filter::GZipRead) if gzip? + #add_filter(Filter::YAML) if yaml? add_line_filters() if closeoneof? add_filter(Filter::CloseOnEOF) ioh.oncloseproc = proc { self.on_closeoneof } end @@ -141,9 +144,10 @@ def add_extensions() Ext::Output.add_extensions(self) end def add_filters add_filter(Filter::GZipWrite) if gzip? + #add_filter(Filter::YAML) if yaml? self end end