rootStreamListener method

  1. @visibleForTesting
void rootStreamListener(
  1. dynamic data
)

Implementation

@visibleForTesting
void rootStreamListener(data) {
  final snapshot = snapmap[data['id']];
  if (snapshot == null) return;

  if (data['type'] == 'data') {
    snapshot.add(data['payload']);
  } else if (data['type'] == 'error') {
    if ((data['payload'] as Map).containsKey('errors')) {
      snapshot.addError(
        HasuraRequestError.fromJson(
          data['payload']['errors'][0],
          request: Request(
            url: '',
            query: const Query(document: ''),
          ),
        ),
      );
    } else {
      snapshot.addError(
        HasuraRequestError.fromJson(
          data['payload'],
          request: Request(
            url: '',
            query: const Query(document: ''),
          ),
        ),
      );
    }
  }
}