lib/rio/scheme/temp.rb in rio-0.3.7 vs lib/rio/scheme/temp.rb in rio-0.3.8

@@ -48,10 +48,11 @@
       attr_reader :prefix,:tmpdir
       def initialize(file_prefix=DFLT_PREFIX,temp_dir=DFLT_TMPDIR)
         #puts "initialize(#{file_prefix.inspect},#{temp_dir.inspect})"
         @prefix = file_prefix || DFLT_PREFIX
         @tmpdir = temp_dir || DFLT_TMPDIR
+        super
       end
       #def path() nil end
       def scheme() self.class.const_get(:RIOSCHEME) end
       def opaque()
         td = self.escape(@tmpdir.to_s)
@@ -88,10 +89,14 @@
           @tmpdir = temp_dir || DFLT_TMPDIR
           require 'rio/tempdir'
           @td = ::Tempdir.new( @prefix.to_s, @tmpdir.to_s)
           super(@td.to_s)
         end
+        def dir_rl() 
+          RIO::Dir::RL.new(self.uri, {:fs => self.fs})
+          #self 
+        end
         SPLIT_RE = Temp::RL::SPLIT_RE
         def self.splitrl(s)
           Temp::RL.splitrl(s)
         end
       end
@@ -110,10 +115,14 @@
           @tmpdir = temp_dir || DFLT_TMPDIR
           require 'tempfile'
           @tf = ::Tempfile.new( @prefix.to_s, @tmpdir.to_s)
           super(@tf.path)
         end
+        def file_rl() 
+        RIO::File::RL.new(self.uri,{:fs => self.fs})
+          #self 
+        end
         def open(mode='ignored')
           #p callstr('open',mode)
           @tf
         end
         def close 
@@ -131,10 +140,14 @@
       def initialize(*args)
         super
         #p args
         @tempobj = nil
       end
+      def self.default_cx
+        Cx::Vars.new( { 'closeoneof' => false, 'closeoncopy' => false } )
+      end
+
       def check?() true end
       def mkdir(prefix=rl.prefix,tmpdir=rl.tmpdir)
         self.rl = RIO::Temp::Dir::RL.new(prefix, tmpdir)
         become 'Dir::Existing'
       end
@@ -168,10 +181,10 @@
     end
     require 'rio/stream/open'
     module Stream
       class Open < RIO::Stream::Open
         def iostate(sym)
-          mode('w+').noautoclose_.open_.inout()
+          mode_('w+').open_.inout()
         end
 #        def inout() stream_state('Temp::Stream::InOut') end
       end
 #      require 'rio/stream'
 #      class InOut < RIO::Stream::InOut