fix handling of return values in testslotqueue
This commit is contained in:
parent
4d1a9e6a51
commit
53115235dc
|
@ -524,7 +524,7 @@ suite "Slot queue":
|
||||||
request.ask,
|
request.ask,
|
||||||
request.expiry,
|
request.expiry,
|
||||||
seen = true)
|
seen = true)
|
||||||
queue.push(item)
|
check queue.push(item).isOk
|
||||||
check eventually queue.paused
|
check eventually queue.paused
|
||||||
check onProcessSlotCalledWith.len == 0
|
check onProcessSlotCalledWith.len == 0
|
||||||
|
|
||||||
|
@ -534,7 +534,7 @@ suite "Slot queue":
|
||||||
|
|
||||||
let request = StorageRequest.example
|
let request = StorageRequest.example
|
||||||
var items = SlotQueueItem.init(request)
|
var items = SlotQueueItem.init(request)
|
||||||
queue.push(items)
|
check queue.push(items).isOk
|
||||||
# check all items processed
|
# check all items processed
|
||||||
check eventually queue.len == 0
|
check eventually queue.len == 0
|
||||||
|
|
||||||
|
@ -546,7 +546,7 @@ suite "Slot queue":
|
||||||
request.expiry,
|
request.expiry,
|
||||||
seen = true)
|
seen = true)
|
||||||
check queue.paused
|
check queue.paused
|
||||||
queue.push(item0)
|
check queue.push(item0).isOk
|
||||||
check queue.paused
|
check queue.paused
|
||||||
|
|
||||||
test "paused queue waits for unpause before continuing processing":
|
test "paused queue waits for unpause before continuing processing":
|
||||||
|
@ -558,7 +558,7 @@ suite "Slot queue":
|
||||||
seen = false)
|
seen = false)
|
||||||
check queue.paused
|
check queue.paused
|
||||||
# push causes unpause
|
# push causes unpause
|
||||||
queue.push(item)
|
check queue.push(item).isOk
|
||||||
# check all items processed
|
# check all items processed
|
||||||
check eventually onProcessSlotCalledWith == @[
|
check eventually onProcessSlotCalledWith == @[
|
||||||
(item.requestId, item.slotIndex),
|
(item.requestId, item.slotIndex),
|
||||||
|
@ -576,8 +576,8 @@ suite "Slot queue":
|
||||||
request.ask,
|
request.ask,
|
||||||
request.expiry,
|
request.expiry,
|
||||||
seen = true)
|
seen = true)
|
||||||
queue.push(item0)
|
check queue.push(item0).isOk
|
||||||
queue.push(item1)
|
check queue.push(item1).isOk
|
||||||
check queue[0].seen
|
check queue[0].seen
|
||||||
check queue[1].seen
|
check queue[1].seen
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue