Weather_Tutorial/lib/model/model_command.dart at master · tut195/Weather_Tutorial · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
import 'package:rx_command/rx_command.dart';
import 'package:geolocation/geolocation.dart';
import 'package:rxdart/rxdart.dart';
// import 'package:rxdart/streams.dart';

import 'package:weather/model/model.dart';
import 'package:weather/model/weather_repo.dart';

class ModelCommand {
  final WeatherRepo weatherRepo;

  // final RxCommand<Null, LocationResult> updateLocationCommand;
  final RxCommand<LocationResult, List<WeatherModel>> updateWeatherCommand;
  final RxCommand<Null, bool> getGpsCommand;
  final RxCommand<bool, bool> radioCheckedCommand;
  final RxCommand<int, Null> addCitiesCommand;
  final RxCommand<String, Null> changeLocaleCommand;
  final RxCommand<dynamic, LocationResult> updateLocationStreamCommand;

  ModelCommand._(
    this.weatherRepo,
    // this.updateLocationCommand,
    this.updateWeatherCommand,
    this.getGpsCommand,
    this.radioCheckedCommand,
    this.addCitiesCommand,
    this.updateLocationStreamCommand,
    this.changeLocaleCommand,
  );

  factory ModelCommand(WeatherRepo repo) {
    final _getGpsCommand = RxCommand.createAsync2<bool>(repo.getGps);

    final _radioCheckedCommand = RxCommand.createSync3<bool, bool>((b) => b);

    final _changeLocaleCommand =
        RxCommand.createSync1<String>(repo.setLanguage);

    //A combined Observable of the GPS and Radio observables using And logic.  If one is false then false will be returned.
    //This allows us to have a more dynamic set of circumstances for shutting down the buttons.
    // final Observable<bool> _boolCombine = Observable
    //     .combineLatest2(_getGpsCommand.results, _radioCheckedCommand.results,
    //         (gps, radio) => gps && radio)
    //     .distinctUnique();

    //Two Observables needed because they are only cold observables (single subscription).
    final _boolCombineA =
        CombineObs(_getGpsCommand.results, _radioCheckedCommand.results)
            .combinedObservable;
    final _boolCombineB =
        CombineObs(_getGpsCommand.results, _radioCheckedCommand.results)
            .combinedObservable;

    // final _updateLocationCommand =
    //     RxCommand.createAsync2<LocationResult>(repo.updateLocation);

    final _updateWeatherCommand = RxCommand
        .createAsync3<LocationResult, List<WeatherModel>>(repo.updateWeather,
            canExecute: _boolCombineA);

    final _addCitiesCommand = RxCommand.createSync1<int>(repo.addCities);

    final _updateLocationStreamCommand = RxCommand
        .createFromStream<dynamic, LocationResult>(repo.updateLocationStream,
            canExecute: _boolCombineB);

    // _updateLocationCommand.results.listen(_updateWeatherCommand);
    //using a stream based command now because lastKnownLocation is not as consistent as [currentLocation]
    _updateLocationStreamCommand.results
        .listen((data) => _updateWeatherCommand(data));

    _updateWeatherCommand(null);

    return ModelCommand._(
      repo,
      // _updateLocationCommand,
      _updateWeatherCommand,
      _getGpsCommand,
      _radioCheckedCommand,
      _addCitiesCommand,
      _updateLocationStreamCommand,
      _changeLocaleCommand,
    );
  }
}

class CombineObs {
  final Observable<bool> _combinedObservable;
  Observable<bool> get combinedObservable => _combinedObservable;
  CombineObs._(this._combinedObservable);

  factory CombineObs(a, b) {
    Observable<bool> c = Observable.combineLatest2(a, b, (x, y) => x && y);
    return CombineObs._(c);
  }
}