aggregate method

Stream<Map<String, dynamic>> aggregate(
  1. List<Map<String, dynamic>> pipeline, {
  2. Transaction? transaction,
})

Implementation

Stream<Map<String, dynamic>> aggregate(
  List<Map<String, dynamic>> pipeline, {
  Transaction? transaction,
}) {
  final bytesList = pipeline.map(
    (e) {
      final bson = BSON();
      final bytes = bson.serialize(e);
      return bytes;
    },
  ).toList();
  final ret = p.aggregate(
    collectionId,
    bytesList,
    requestContext: transaction?.requestContext,
  );
  return ret;
}