streamTestByDocumentId method

Stream<Test> streamTestByDocumentId(
  1. String docId
)

Implementation

Stream<Test> streamTestByDocumentId(String docId) {
  final realtime = Realtime(_db.client);
  final subscription = realtime.subscribe([
    'databases.$databaseId.collections.$collectionId.documents.$docId',
  ]);
  return subscription.stream.map((event) {
    return Test.fromMap(event.payload, docId);
  });
}