stream method

Stream stream(
  1. JSAny? data,
  2. HttpsCallableStreamOptions? options
)

Implementation

Stream<dynamic> stream(JSAny? data,
    functions_interop.HttpsCallableStreamOptions? options) async* {
  final streamCallable = await (jsObject as functions_interop.HttpsCallable)
      .stream(data, options)
      .toDart;
  final streamResult =
      streamCallable! as functions_interop.HttpsCallableStreamResultJsImpl;

  await for (final value in streamResult.stream.asStream()) {
    // ignore: invalid_runtime_check_with_js_interop_types
    final message = value is JSObject
        ? HttpsCallableStreamResult.getInstance(
            value as functions_interop.HttpsStreamIterableResult,
          ).data
        : value;
    yield {'message': message};
  }

  final result = await streamResult.data.toDart;
  yield {'result': result};
}