initialise method

@override void initialise()

Implementation

@override
void initialise() {
  _streamSubscription = stream.listen(
    (incomingData) {
      setError(null);
      setMessage(null);
      // Extra security in case transformData isnt sent
      var interceptedData = transformData(incomingData);

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

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

  onSubscribed();
  changeSource = false;
}