Class: Async::HTTP::Body::Pipe

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/async/http/body/pipe.rb

Instance Method Summary collapse

Constructor Details

#initialize(input, output = Writable.new, task: Task.current) ⇒ Pipe

Returns a new instance of Pipe.



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/async/http/body/pipe.rb', line 33

def initialize(input, output = Writable.new, task: Task.current)
	@input = input
	@output = output
	
	head, tail = IO::Socket.pair(Socket::AF_UNIX, Socket::SOCK_STREAM)
	
	@head = Async::IO::Stream.new(head)
	@tail = tail
	
	@reader = nil
	@writer = nil
	
	task.async(&self.method(:reader))
	task.async(&self.method(:writer))
end

Instance Method Details

#close ⇒ Object 



53
54
55
56
57
58
 
# File 'lib/async/http/body/pipe.rb', line 53

def close
	@reader&.stop
	@writer&.stop
	
	@tail.close
end

#to_io ⇒ Object 



49
50
51
 
# File 'lib/async/http/body/pipe.rb', line 49

def to_io
	@tail
end