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!();
}