getStream method

Future<Stream<List<int>>?> getStream(
  1. String name, {
  2. int? cacheTtl,
})

Implementation

Future<Stream<List<int>>?> getStream(
  String name, {
  int? cacheTtl,
}) async {
  final stream = await _delegate.get(
    name,
    interop.KVNamespaceGetOptions()
      ..type = 'stream'
      ..cacheTtl = cacheTtl,
  );

  if (stream == null) {
    return null;
  }

  final reader = callMethod<ReadableStreamDefaultReader>(
    stream,
    'getReader',
    [],
  );

  return streamFromJSReader(reader);
}