streamFactsForUser method

ValueStream<Facts> streamFactsForUser(
  1. MKey userId
)

Implementation

ValueStream<Facts> streamFactsForUser(MKey userId) {
  return ValueStream.of(
    getFactsForContact(userId),
    factStream
        .where((fact) => fact.involves(userId))
        .asyncMapSample((_) async {
      return await getFactsForContact(userId);
    }),
  );
}