lib/rio/stream/open.rb in rio-0.5.1 vs lib/rio/stream/open.rb in rio-0.6.0

- old
+ new

@@ -1,8 +1,8 @@ #-- # =========================================================================== -# Copyright (c) 2005-2012 Christopher Kleckner +# Copyright (c) 2005-2017 Christopher Kleckner # All rights reserved # # This file is part of the Rio library for ruby. # # Rio is free software; you can redistribute it and/or modify @@ -20,15 +20,11 @@ # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA # =========================================================================== #++ # - -#require 'rio/ioh' require 'rio/stream/base' -#require 'rio/ops/stream' -#require 'rio/ops/path' require 'rio/cp' require 'rio/piper/cp' require 'rio/util' require 'rio/ops' @@ -37,11 +33,10 @@ class Open < Base include Ops::Stream::Status include Ops::Path::URI include Cp::Open::Output include Cp::Open::Input - ##include Piper::Cp::Input def check?() true end def open(m=nil,*args) #p callstr('open',m,*args) @@ -70,13 +65,10 @@ module Stream class Open < Base public - #def size() self.contents.size end - #def empty?() self.eof? end - def iostate(sym) if mode? && mode?.allows_both? open_.inout() else implicit_state(sym) @@ -96,11 +88,10 @@ gofigure(sym,*args) end def stream_state(cl) #p callstr('stream_state',cl) - #p "LOOP: retry:#{cx['retrystate']} => #{cl}" return nil if cx['retrystate'] == cl cx['retrystate'] = cl become(cl).add_rec_methods.add_extensions.add_filters.setup end @@ -170,10 +161,9 @@ end def close_() #p callstr('close_')+" mode='#{mode?}' ioh=#{self.ioh} open?=#{open?}" return self unless self.open? - #clear_selection self.ioh.close self.ioh = nil self.rl.close self end