readRequest method

@override Future<WorkRequest?> readRequest()

Reads a WorkRequest or returns null if there are none left.

See AsyncWorkerConnection and SyncWorkerConnection for more narrow interfaces.

Implementation

@override
Future<WorkRequest?> readRequest() async {
  var buffer = await _messageGrouper.next;
  if (buffer == null) return null;

  return WorkRequest.fromBuffer(buffer);
}