1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
require File.expand_path(File.join(File.dirname(__FILE__), 'helper'))
require 'async'
class TestFiberDebug < Test::Unit::TestCase
include TestServerMethods
def setup
server_setup
end
def test_simple_fiber_request
puts "\n=== Starting simple fiber request test ==="
run_async do |task|
puts "Inside Async block"
puts "Fiber scheduler available: #{Curl::Multi.fiber_scheduler_available?}"
multi = Curl::Multi.new
easy = Curl::Easy.new(TestServlet.url)
easy.on_complete { |curl| puts "Request completed: #{curl.response_code}" }
multi.add(easy)
puts "Added easy handle to multi"
# Perform without block first
puts "Calling perform..."
multi.perform
puts "Perform completed"
end
puts "Test completed"
end
def test_fiber_with_block
puts "\n=== Starting fiber with block test ==="
run_async do |task|
puts "Inside Async block"
multi = Curl::Multi.new
easy = Curl::Easy.new(TestServlet.url_to("/slow?seconds=0.1"))
easy.on_complete { |curl| puts "Request completed: #{curl.response_code}" }
multi.add(easy)
block_calls = 0
multi.perform do
block_calls += 1
puts "Block called: #{block_calls}"
if block_calls < 5 # Limit iterations to prevent infinite loop
Async::Task.yield
end
end
puts "Perform completed, block called #{block_calls} times"
end
puts "Test completed"
end
private
def run_async(&block)
if defined?(Async) && Async.respond_to?(:run)
Async.run(&block)
else
Async(&block)
end
end
end
|
