Cómo crear un API de transmisión para Flutter para suscribirse.

Estoy tratando de obtener mensajes de una API que construí en express en Flutter.

La cosa es que, para obtener mis mensajes, tuve que construir un StreamBuilder porque quiero que la lista de mensajes se actualice con nuevos mensajes. Para lograr esto, creé un método de streaming que revisa la API cada x segundos.

  Stream<List<Message>> streamMessage() async* {
    final storage = FlutterSecureStorage();
    var json = (await storage.read(key: 'user'))!;
    User user = User.fromJson(jsonDecode(json));
    jwt = user.jwt;

yield* Stream.periodic(const Duration(seconds: 3), (_) async {
  http.Response response = await http.get(
      Uri.parse("https://miapi.com/mensajes"),
      headers: {
        'Authorization': 'Bearer $jwt',
      });

  List<Message> mensajes = [];
  if (response.statusCode == 200) {
    var lista = List.from(jsonDecode(response.body)).reversed;
    mensajes = lista.map((e) => Message.fromJson(e)).toList();
  } else {
    log("Error : ${response.statusCode} -- ${response.reasonPhrase}");
  }
  return mensajes;
}).asyncMap(
  (value) async => await value,
);
}

Funciona, pero tiene muchos problemas.
– La actualización no es tan rápida como quiero
– Hay muchas solicitudes innecesarias
– La API se puede sobrecargar fácilmente
– Esta forma parece más un truco que una función real

Me gustaría crear un mecanismo en mi backend que funcione más como una suscripción real de transmisión. Como funciona con Firebase. Pero no tengo idea de cómo funciona eso, ni siquiera qué buscar.

Si tienes alguna pista, ¿cómo puedo lograr esto?