applyInbound method

Future<void> applyInbound(
  1. TTGraphData diff
)

Applies an inbound graph diff by merging and persisting via the store.

Implementation

Future<void> applyInbound(TTGraphData diff) async {
  await _store.writeGraph(diff);
  // Notify subscribers with a synthetic change event per soul
  for (final entry in diff.entries) {
    _controller.add(Tuple<String, TTGraphData>(
      item1: entry.key,
      item2: (TTGraphData()..[entry.key] = entry.value),
    ));
  }
}