in lib/src/worker/worker_connection.dart [62:67]
Future<WorkRequest?> readRequest() async { var buffer = await _messageGrouper.next; if (buffer == null) return null; return WorkRequest.fromBuffer(buffer); }