Skip to content

Commit b2e365d

Browse files
committed
Use Ractor#value instead of take
1 parent 95c0525 commit b2e365d

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

test/ractor_test.rb

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,8 @@ def test_non_frozen(data)
88
dtype = data.fetch(:dtype)
99
ary = random_array(dtype)
1010
r = Ractor.new(ary) {|x| x }
11-
ary2 = r.take
11+
# Use Ractor#value in Ruby 3.5+, fallback to #take for older versions
12+
ary2 = r.respond_to?(:value) ? r.value : r.take
1213
assert_equal(ary, ary2)
1314
assert_not_same(ary, ary2)
1415
end
@@ -20,7 +21,8 @@ def test_frozen(data)
2021
r = Ractor.new(ary1) do |ary2|
2122
[ary2, ary2 * 10]
2223
end
23-
ary2, res = r.take
24+
# Use Ractor#value in Ruby 3.5+, fallback to #take for older versions
25+
ary2, res = r.respond_to?(:value) ? r.value : r.take
2426
assert_equal((dtype != Numo::RObject),
2527
ary1.equal?(ary2))
2628
assert_equal(ary1*10, res)
@@ -35,7 +37,10 @@ def test_parallel(data)
3537
r2 = Ractor.new(ary1) do |ary4|
3638
ary4 * 10
3739
end
38-
assert_equal(r1.take, r2.take)
40+
# Use Ractor#value in Ruby 3.5+, fallback to #take for older versions
41+
result1 = r1.respond_to?(:value) ? r1.value : r1.take
42+
result2 = r2.respond_to?(:value) ? r2.value : r2.take
43+
assert_equal(result1, result2)
3944
end
4045

4146
def random_array(dtype, n=1000)

0 commit comments

Comments
 (0)