onWebsocketData method

@protected void onWebsocketData(dynamic data)

The websocket's data handler.

Forwards incoming notifications to their dispatchers.

Implementation

@protected
void onWebsocketData(final dynamic data) {
  try {
    final response = JsonRpcNotificationResponse.fromJson(data);
    final SubscriptionId subscriptionId = response.params.subscription;
    final WebsocketNotifier? notifier = _notifiers[subscriptionId];
    if (notifier != null) {
      notifier.notifyData(response.params.result);
      if (notifier.autoUnsubscribes) {
        _close(subscriptionId);
      }
    } else {
      final String method = response.method;
      _unsubscribe(method, subscriptionId).ignore();
    }
  } catch (error) {
    // print('Notification data $data');
    // print('Notification error $error');
  }
}