class Async::IO::Stream

def close
	return if @io.closed?
	
	begin
		flush
	rescue
		# We really can't do anything here unless we want #close to raise exceptions.
		Async.logger.error(self) {$!}
	ensure
		@io.close
	end
end