writeTo method

Future<int> writeTo(
  1. IOSink out
)

Implementation

Future<int> writeTo(IOSink out) {
  var length = 0;
  var completer = Completer<int>();
  void addToSink(Map<String, dynamic> chunk) {
    final data = chunk['data'] as BsonBinary;
    out.add(data.byteList);
    length += data.byteList.length;
  }

  fs.chunks
      .find(where.eq('files_id', id).sortBy('n'))
      .forEach(addToSink)
      .then((_) => completer.complete(length));
  return completer.future;
}