Stream<Object?> get messages => _socket.map((event) { if (event is String) return jsonDecode(event); return event; });