Comme d’habitude, poster c’est trouver :
channel.stream.listen(
(message) {
print("message = $message");
final data = jsonDecode(message);
if (data['type'] == 'auth' && data['status'] == 'ok') {
subscribe();
}
if (data['type'] == 'ping') {
channel.sink.add(jsonEncode({'type': 'pong'}));
print({'event': 'onmessage', 'data': data});
}
},
onError: (error) {
print({'event': 'onerror', 'error': error});
},
onDone: () {
print({'event': 'onclose'});
},
);