state property

Stream<FirestoreGatewayState> get state

Implementation

Stream<FirestoreGatewayState> get state {
  return Rx.combineLatest3(pendingWrites, mode, connectionStatus, (
    int pending,
    GatewayMode mode,
    ConnectionStatus status,
  ) {
    return FirestoreGatewayState(
      isInitialized: _isInitialized,
      isOnline: status == ConnectionStatus.connected,
      mode: mode,
      pendingWrites: pending,
    );
  });
}