bind method

Future<void> bind(
  1. QueueEventSource source
)

Folds prior history then subscribes to live QueueEventSource.events.

Implementation

Future<void> bind(QueueEventSource source) async {
  for (final e in await source.history(limit: maxTasks)) {
    apply(e, broadcast: false);
  }
  _sub = source.events().listen(apply);
}