setNetworkStream static method

void setNetworkStream(Stream<bool> stream)

Set a stream to monitor network connectivity status.

ZenQuery will listen to this stream and automatically refetch stale queries when connectivity is restored (if configured).

Example with connectivity_plus:

Zen.setNetworkStream(
  Connectivity().onConnectivityChanged.map(
    (results) => !results.contains(ConnectivityResult.none)
  )
);

Implementation

static void setNetworkStream(Stream<bool> stream) {
  // Broadcast it so multiple listeners can attach
  final broadcast = stream.isBroadcast ? stream : stream.asBroadcastStream();
  ZenQueryCache.instance.setNetworkStream(broadcast);
  ZenMutationQueue.instance.setNetworkStream(broadcast);
}