debugRegisterStreamRefresher function

  1. @visibleForTesting
void debugRegisterStreamRefresher(
  1. String key,
  2. Future<void> refresh()
)

Registers a refresher directly.

Tests only — in production this happens when a query's stream is first listened to. Exposed because the registry is private to this library and the property worth testing is which refreshers a write runs.

Implementation

@visibleForTesting
void debugRegisterStreamRefresher(String key, Future<void> Function() refresh) {
  _refreshers[key] = refresh;
}