watch method

Stream<Map<String, dynamic>> watch(
  1. List<Map<String, dynamic>> pipeline
)

Implementation

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