onMessage method

Implementation

@override
onMessage(String message) {
  // enabled?
  if (!enabled) return;

  // increment the number of messages received
  _received.set(received + 1);

  // set last message bindable
  _message.set(message);

  // deserialize the data
  Data data = Data.from(message, root: root);

  // if the message didn't deserialize (length 0)
  // so create a simple map with message bindable <id>.data.message
  // otherwise the data is the deserialized message payload
  if (data.isEmpty) data.insert(0, {'message': message});

  // fire the onresponse
  onSuccess(data, code: HttpStatus.ok, onSuccessOverride: _onmessage);
}