watch method

T? watch(BuildContext context)

This function automatically updates the enclosing widget when a new element is added to the stream

Implementation

T? watch(BuildContext context) {
  //If this state hasn't already been registered to update with this stream
  if (StreamState._contextsExpando[this] == null) {
    StreamState._contextsExpando[this] = {};
    StreamState._streamSubs[this] = listen((event) {
      if (StreamState._dataExpando[this] != event) {
        StreamState._dataExpando[this] = event;
        //Stop listening for changes if there are no states left
        if (StreamState._contextsExpando[this]!.isEmpty) {
          StreamState._streamSubs[this]!.cancel();
          StreamState._contextsExpando[this] = null;
        } else {
          //Otherwise call setState on each registered state
          StreamState._contextsExpando[this]!.removeWhere((itContext) {
            //Calling the rebuild within remove is probably very bad practice
            //but it's a pretty good way of only iterating once
            try {
              //This seems mad: the only way I found to get the
              //current element is to get the ancestor, then the child
              itContext.visitAncestorElements((element) {
                element.visitChildElements((element) {
                  element.markNeedsBuild();
                });
                return false;
              });
              return false;
            } on FlutterError catch (_) {
              return true;
            }
          });
        }
      }
    });
  }

  StreamState._contextsExpando[this]!.add(context);
  //Return the latest value of the stream
  return StreamState._dataExpando[this] as T?;
}