class Falcon::Adapters::Hijack

def self.for(env, block, socket = nil, task: Async::Task.current)
	input = socket || env[Rack::RACK_INPUT]
	output = Async::HTTP::Body::Writable.new
	
	stream = Hijack.new(input, output)
	
	task.async do
		begin
			block.call(stream)
		ensure
			output.close
		end
	end
	
	return output
end

def close
	@output.close
end

def close_read
	if @input.respond_to?(:close_read)
		@input.close_read
	else
		@input.close
	end
end

def close_write
	@output.close
end

def flush
end

def initialize(input, output)
	@input = input
	@output = output
end

def read(length = nil, buffer = nil)
	@input.read(length, buffer)
end

def read_nonblock(length, buffer = nil)
	@input.read(length, buffer)
end

def write(buffer)
	@output.write(buffer)
end