anchor.diff:  import 'dart:async';
   import 'dart:convert';
   import 'dart:io';
  +import 'dart:typed_data';
   
   import 'package:meta/meta.dart';
   
   import '../common.dart';
  +import '../hash_codes.dart';
   import '../metrics.dart';
   import '../temperature.dart';
   import '../watch_stream.dart';
  
positive.code:     return command.result;
    }
  
    bool get _connectionRequired => _temperatureSubscriptionActive || _statusSubscriptionActive || _commands.isNotEmpty;
  
    Future<Null> _initialize() async {
      while (_active) {
  
negative.code:   }) {
      _temperature = new HandlerWatchStream<Temperature>(_startPollingTemperature, _endPollingTemperature);
      _status = new HandlerWatchStream<ThermostatStatus>(_startPollingStatus, _endPollingStatus);
      _report = new HandlerWatchStream<ThermostatReport>(_startPollingReport, _endPollingReport);
      _initialize();
    }
  
  