More general handling of IO instance_methods.

Author: ioquatix

lib/async/io/generic.rb

@@ -75,17 +75,39 @@ def wrap(*args)
 				end
 			end
 
-			wraps ::IO, :external_encoding, :internal_encoding, :autoclose?, :autoclose=, :pid, :stat, :binmode, :flush, :set_encoding, :to_io, :to_i, :reopen, :fileno, :fsync, :fdatasync, :sync, :sync=, :tell, :seek, :rewind, :pos, :pos=, :eof, :eof?, :close_on_exec?, :close_on_exec=, :closed?, :close_read, :close_write, :isatty, :tty?, :binmode?, :sysseek, :advise, :ioctl, :fcntl
+			wraps ::IO, :external_encoding, :internal_encoding, :autoclose?, :autoclose=, :pid, :stat, :binmode, :flush, :set_encoding, :to_io, :to_i, :reopen, :fileno, :fsync, :fdatasync, :sync, :sync=, :tell, :seek, :rewind, :pos, :pos=, :eof, :eof?, :close_on_exec?, :close_on_exec=, :closed?, :close_read, :close_write, :isatty, :tty?, :binmode?, :sysseek, :advise, :ioctl, :fcntl, :nread, :ready?, :pread, :pwrite, :pathconf
 
 			# @example
 			#   data = io.read(512)
 			wrap_blocking_method :read, :read_nonblock
 			alias sysread read
+			alias readpartial read
 
 			# @example
 			#   io.write("Hello World")
 			wrap_blocking_method :write, :write_nonblock
 			alias syswrite write
+			alias << write
+			
+			def wait(timeout = nil, mode = :read)
+				case mode
+				when :read
+					wait_readable(timeout)
+				when :write
+					wait_writable(timeout)
+				else
+					wait_any(:rw, timeout)
+				end
+			end
+			
+			def nonblock
+				true
+			end
+			alias nonblock= nonblock
+			
+			def nonblock?
+				true
+			end
 
 			protected
 

spec/async/io/generic_examples.rb

@@ -1,7 +1,7 @@
 
 RSpec.shared_examples Async::IO::Generic do |ignore_methods|
 	let(:instance_methods) {described_class.wrapped_klass.instance_methods(false) - (ignore_methods || [])}
-	let(:wrapped_instance_methods) {described_class.instance_methods(false)}
+	let(:wrapped_instance_methods) {described_class.instance_methods}
 
 	it "should wrap a class" do
 		expect(described_class.wrapped_klass).to_not be_nil

spec/async/io/generic_spec.rb

@@ -25,7 +25,9 @@
 RSpec.describe Async::IO::Generic do
 	include_context Async::RSpec::Reactor
 
-	# it_should_behave_like Async::IO::Generic
+	it_should_behave_like Async::IO::Generic, [
+		:bytes, :chars, :codepoints, :each, :each_byte, :each_char, :each_codepoint, :each_line, :getbyte, :getc, :gets, :lineno, :lineno=, :lines, :print, :printf, :putc, :puts, :readbyte, :readchar, :readline, :readlines, :ungetbyte, :ungetc
+	]
 
 	let(:pipe) {IO.pipe}
 	let(:input) {Async::IO::Generic.new(pipe.first)}

spec/async/io/socket_spec.rb

@@ -23,7 +23,7 @@
 require_relative 'generic_examples'
 
 RSpec.describe Async::IO::BasicSocket do
-	it_should_behave_like Async::IO::Generic, [:read_nonblock, :write_nonblock]
+	it_should_behave_like Async::IO::Generic
 end
 
 RSpec.describe Async::IO::Socket do

spec/async/io/ssl_socket_spec.rb

@@ -27,7 +27,7 @@
 	include_context Async::RSpec::Reactor
 	include_context Async::RSpec::SSL::VerifiedContexts
 
-	it_should_behave_like Async::IO::Generic, [:sync_close, :to_io, :io]
+	it_should_behave_like Async::IO::Generic
 
 	# Shared port for localhost network tests.
 	let(:endpoint) {Async::IO::Endpoint.tcp("127.0.0.1", 6779, reuse_port: true)}