take method

Future<DataFrame> take()

Implementation

Future<DataFrame> take() async {
  final lease = _begin();
  var release = true;
  try {
    final response = await _runtime._client.invoke('jobTake', {
      'job': lease.handle.toString(),
    });
    if (response['ready'] != true) {
      release = false;
      throw StateError('Job result is not ready');
    }
    return _runtime._adoptFrame(response);
  } finally {
    if (release) _owner.close();
    _end(lease);
  }
}