initialise method

void initialise()

Implementation

void initialise() {
  _streamSubscription = stream.listen(
    (incomingData) {
      setError(null);
      setMessage(null);
      _error = null;
      notifyListeners();
      // Extra security in case transformData isnt sent
      var interceptedData =
          transformData == null ? incomingData : transformData!(incomingData);

      if (interceptedData != null) {
        _data = interceptedData;
      } else {
        _data = incomingData;
      }

      notifyListeners();
      onData!(_data);
    },
    onError: (error) {
      setError(error);
      _data = null;
      onError!(error);
      notifyListeners();
    },
  );

  onSubscribed!();
}