diff options
| author | Benoit Germain <benoit.germain@ubisoft.com> | 2024-12-13 17:22:17 +0100 |
|---|---|---|
| committer | Benoit Germain <benoit.germain@ubisoft.com> | 2024-12-13 17:22:17 +0100 |
| commit | dc7a2bc3a9c8316e17902493b832ca117805d29f (patch) | |
| tree | 3c1a03edf586869119ef0de03631f6f603650720 /unit_tests/scripts/lane/tasking_error.lua | |
| parent | 7500a80fc06c5311c46df8f1761f25ae67277fc4 (diff) | |
| download | lanes-dc7a2bc3a9c8316e17902493b832ca117805d29f.tar.gz lanes-dc7a2bc3a9c8316e17902493b832ca117805d29f.tar.bz2 lanes-dc7a2bc3a9c8316e17902493b832ca117805d29f.zip | |
Append all unit tests to depot
Diffstat (limited to 'unit_tests/scripts/lane/tasking_error.lua')
| -rw-r--r-- | unit_tests/scripts/lane/tasking_error.lua | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/unit_tests/scripts/lane/tasking_error.lua b/unit_tests/scripts/lane/tasking_error.lua new file mode 100644 index 0000000..1e2347f --- /dev/null +++ b/unit_tests/scripts/lane/tasking_error.lua | |||
| @@ -0,0 +1,49 @@ | |||
| 1 | local require_lanes_result_1, require_lanes_result_2 = require "lanes".configure(config).configure() | ||
| 2 | print("require_lanes_result:", require_lanes_result_1, require_lanes_result_2) | ||
| 3 | local lanes = require_lanes_result_1 | ||
| 4 | |||
| 5 | local require_assert_result_1, require_assert_result_2 = require "_assert" | ||
| 6 | print("require_assert_result:", require_assert_result_1, require_assert_result_2) | ||
| 7 | |||
| 8 | local utils = lanes.require "_utils" | ||
| 9 | local PRINT = utils.MAKE_PRINT() | ||
| 10 | |||
| 11 | local lanes_gen = assert(lanes.gen) | ||
| 12 | local lanes_linda = assert(lanes.linda) | ||
| 13 | |||
| 14 | -- ################################################################################################## | ||
| 15 | -- ################################################################################################## | ||
| 16 | -- ################################################################################################## | ||
| 17 | |||
| 18 | local gc_cb = function(name_, status_) | ||
| 19 | PRINT(" ---> lane '" .. name_ .. "' collected with status '" .. status_ .. "'") | ||
| 20 | end | ||
| 21 | |||
| 22 | PRINT("---=== Tasking (error) ===---", "\n\n") | ||
| 23 | |||
| 24 | -- a lane that throws immediately the error value it received | ||
| 25 | local g = lanes_gen("", {gc_cb = gc_cb}, error) | ||
| 26 | local errmsg = "ERROR!" | ||
| 27 | |||
| 28 | if true then | ||
| 29 | -- if you index an errored lane, it should throw the error again | ||
| 30 | local lane = g(errmsg) | ||
| 31 | assert.fails(function() return lane[1] end) | ||
| 32 | assert(lane.status == "error") | ||
| 33 | -- even after indexing, joining a lane in error should give nil,<error> | ||
| 34 | local a,b = lane:join() | ||
| 35 | assert(a == nil and string.find(b, errmsg)) | ||
| 36 | end | ||
| 37 | |||
| 38 | if true then | ||
| 39 | local lane = g(errmsg) | ||
| 40 | -- after indexing, joining a lane in error should give nil,<error> | ||
| 41 | local a, b = lane:join() | ||
| 42 | assert(lane.status == "error") | ||
| 43 | assert(a == nil and string.find(b, errmsg)) | ||
| 44 | -- even after joining, indexing should raise an error | ||
| 45 | assert.fails(function() return lane[1] end) | ||
| 46 | -- unless we index with a negative value to get the error message | ||
| 47 | local c = lane[-1] | ||
| 48 | assert(c == b) | ||
| 49 | end | ||
