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