rootStreamListener method
void
rootStreamListener(
- 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: ''),
),
),
);
}
}
}