lib/polyphony/extensions/io.rb in polyphony-0.13 vs lib/polyphony/extensions/io.rb in polyphony-0.14

@@ -12,51 +12,52 @@
   def stop_watchers
     @read_watcher&.stop
     @write_watcher&.stop
   end
 
-  NO_EXCEPTION = { exception: false }.freeze
+  # NO_EXCEPTION = { exception: false }.freeze
 
-  def read(max = 8192, outbuf = nil)
-    outbuf ||= (@read_buffer ||= +'')
-    loop do
-      result = read_nonblock(max, outbuf, NO_EXCEPTION)
-      case result
-      when nil            then raise IOError
-      when :wait_readable then read_watcher.await
-      else                return result
-      end
-    end
-  ensure
-    @read_watcher&.stop
-  end
+  # def read(max = 8192, outbuf = nil)
+  #   outbuf ||= (@read_buffer ||= +'')
+  #   loop do
+  #     result = read_nonblock(max, outbuf, NO_EXCEPTION)
+  #     case result
+  #     when nil            then raise IOError
+  #     when :wait_readable then read_watcher.await
+  #     else                return result
+  #     end
+  #   end
+  # ensure
+  #   @read_watcher&.stop
+  # end
 
-  def write(data)
-    loop do
-      result = write_nonblock(data, NO_EXCEPTION)
-      case result
-      when nil            then raise IOError
-      when :wait_writable then write_watcher.await
-      else
-        (result == data.bytesize) ? (return result) : (data = data[result..-1])
-      end
-    end
-  ensure
-    @write_watcher&.stop
-  end
+  # def write(data)
+  #   loop do
+  #     result = write_nonblock(data, NO_EXCEPTION)
+  #     case result
+  #     when nil            then raise IOError
+  #     when :wait_writable then write_watcher.await
+  #     else
+  #       (result == data.bytesize) ? (return result) : (data = data[result..-1])
+  #     end
+  #   end
+  # ensure
+  #   @write_watcher&.stop
+  # end
 
-  def write_list(*list)
-    list.each do |data|
-      loop do
-        result = write_nonblock(data, NO_EXCEPTION)
-        case result
-        when nil            then raise IOError
-        when :wait_writable then write_watcher.await
-        else
-          (result == data.bytesize) ? (break result) : (data = data[result..-1])
-        end
-      end
-    end
-  ensure
-    @write_watcher&.stop
-  end
+  # # write_list is inspired by 
+  # def write_list(*list)
+  #   list.each do |data|
+  #     loop do
+  #       result = write_nonblock(data, NO_EXCEPTION)
+  #       case result
+  #       when nil            then raise IOError
+  #       when :wait_writable then write_watcher.await
+  #       else
+  #         (result == data.bytesize) ? (break result) : (data = data[result..-1])
+  #       end
+  #     end
+  #   end
+  # ensure
+  #   @write_watcher&.stop
+  # end
 end
\ No newline at end of file