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