Class: SmartQueue
Name |
---|
Item |
• new SmartQueue(
items
, retry_cnt?
, ...rest
)Type parameters
Name |
---|
Item |
Parameters
Name | Type | Default value |
---|---|---|
items | Item [] | undefined |
retry_cnt | number | 2 |
...rest | any [] | undefined |
Defined in
•
Private
__done: any
Defined in
•
Private
__eof: any
Defined in
•
Private
__new_items: any
Defined in
Defined in
•
Private
_items: null
| Item
[]Defined in
Defined in
Parameters
Name | Type |
---|---|
consumer |
Returns
Defined in
▸ __have_data():
boolean
Returns
boolean
Defined in
▸ close():
void
Returns
void
Defined in
Parameters
Name | Type |
---|---|
consumer | |
callback | undefined | null | Function |
Returns
Defined in
▸ has_unassigned_items():
boolean
Returns
boolean
Defined in
▸ mark_done(
handle
): Promise
Parameters
Name | Type |
---|---|
handle |
Returns
Promise
Defined in
Returns
Defined in
▸ reschedule(
handle
): Promise
Parameters
Name | Type |
---|---|
handle |
Returns
Promise
Defined in
▸ reschedule_all(
consumer
): Promise
Parameters
Name | Type |
---|---|
consumer |
Returns
Promise
Defined in
▸ stats():
object
Returns
object
Defined in
▸ wait_until_done():
Promise
Returns
Promise
Defined in
Last modified 1yr ago