Class: Async::Wrapper Deprecated

Inherits:
Object
  • Object
show all
Defined in:
lib/async/wrapper.rb

Overview

Deprecated.

With no replacement. Prefer native interfaces.

Represents an asynchronous IO within a reactor.

Defined Under Namespace

Classes: Cancelled

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(io, reactor = nil) ⇒ Wrapper

Returns a new instance of Wrapper.



17
18
19
20
21
22
 
# File 'lib/async/wrapper.rb', line 17

def initialize(io, reactor = nil)
	@io = io
	@reactor = reactor
	
	@timeout = nil
end

Instance Attribute Details

#io ⇒ Object (readonly)

The underlying native ‘io`.



31
32
33
 
# File 'lib/async/wrapper.rb', line 31

def io
  @io
end

#reactor ⇒ Object

Returns the value of attribute reactor.



24
25
26
 
# File 'lib/async/wrapper.rb', line 24

def reactor
  @reactor
end

Instance Method Details

#close ⇒ Object

Close the io and monitor.



55
56
57
 
# File 'lib/async/wrapper.rb', line 55

def close
	@io.close
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


59
60
61
 
# File 'lib/async/wrapper.rb', line 59

def closed?
	@io.closed?
end

#dup ⇒ Object 



26
27
28
 
# File 'lib/async/wrapper.rb', line 26

def dup
	self.class.new(@io.dup)
end

#wait_any(timeout = @timeout) ⇒ Object

Wait fo the io to become either readable or writable.



50
51
52
 
# File 'lib/async/wrapper.rb', line 50

def wait_any(timeout = @timeout)
	@io.to_io.wait(::IO::READABLE|::IO::WRITABLE|::IO::PRIORITY, timeout) or raise TimeoutError
end

#wait_priority(timeout = @timeout) ⇒ Object

Wait for the io to become writable.



39
40
41
 
# File 'lib/async/wrapper.rb', line 39

def wait_priority(timeout = @timeout)
	@io.to_io.wait_priority(timeout) or raise TimeoutError
end

#wait_readable(timeout = @timeout) ⇒ Object

Wait for the io to become readable.



34
35
36
 
# File 'lib/async/wrapper.rb', line 34

def wait_readable(timeout = @timeout)
	@io.to_io.wait_readable(timeout) or raise TimeoutError
end

#wait_writable(timeout = @timeout) ⇒ Object

Wait for the io to become writable.



44
45
46
 
# File 'lib/async/wrapper.rb', line 44

def wait_writable(timeout = @timeout)
	@io.to_io.wait_writable(timeout) or raise TimeoutError
end