blob: 3a29e5583c6b53c1ea2396c921ff785742bc1f27 (
plain)
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
|
local fixture = require "fixture"
local lanes = require "lanes".configure{on_state_create = fixture.on_state_create}
local fixture = require "fixture"
lanes.finally(fixture.throwing_finalizer)
local utils = lanes.require "_utils"
local PRINT = utils.MAKE_PRINT()
--------------------------------------------------
-- TEST: cancelling a suspended Lane should end it
--------------------------------------------------
if true then
-- the generator
local coro_g = lanes.coro("*", utils.yield_one_by_one)
-- start the lane
local h = coro_g("hello", "world", "!")
repeat until h.status == "suspended"
-- first cancellation attempt: don't wake the lane
local b, r = h:cancel("soft", 0.5)
-- the lane is still blocked in its suspended state
assert(b == false and r == "timeout" and h.status == "suspended", "got " .. tostring(b) .. " " .. tostring(r) .. " " .. h.status)
-- cancel the Lane again, this time waking it. it will resume, and yielder()'s will break out of its infinite loop
h:cancel("soft", nil, true)
-- lane should be done, because it returned cooperatively when detecting a soft cancel
assert(h.status == "done", "got " .. h.status)
end
|
