pending method

  1. @override
Future<List<DVJobEnvelope<DVJobPayload>>> pending(
  1. String queue
)
override

Implementation

@override
Future<List<DVJobEnvelope<DVJobPayload>>> pending(String queue) async =>
    throw UnsupportedError(
      'A Kafka backlog is the distance between the committed offset and the '
      'end of the log, not a list of messages. `lag` gives that number.',
    );