rknell/dart_queue

The remainingItems stream is not returning any value

Closed this issue · 0 comments

`class FutureQueueService {
static final FutureQueueService _singleton = FutureQueueService._internal();

factory FutureQueueService() {
return _singleton;
}

FutureQueueService._internal() {
queue = Queue();
final remainingItemsStream = queue.remainingItems
.listen((numberOfItems) => log('numberOfItems $numberOfItems'));
}

}`

The queue is able to complete all the future task one-by-one, but the stream is not begin called atall.
The log isnt getting printed.