Tag: AKKA-STREAM
Estoy tratando de obtener un arreglo de bytes de mi modelo para ponerlo en el archivo. Tengo un método de la siguiente manera: public static byte[] GetByteArray(List<mymodel> models) { using var ms = new MemoryStream(); using var sw = new StreamWriter(ms); foreach (var model in models) { sw.Write(model.Id + “,” . . . Read more
boolean isRoleOld,isRoleNew; for (Relations relation : listOfRelations) { if (Constants.ROLE_OLD.equalsIgnoreCase(relation.getRole())) { isRoleOld = true; } if (Constants.ROLE_NEW.equalsIgnoreCase(relation.getRole())) { isRoleNew = true; } } if (isRoleOld && isRoleNew) { “Success” }else{ throw Exception(); } Lo que he hecho hasta ahora es: if (listOfRelations.stream() .anyMatch(relation -> Constants.ROLE_OLD.equalsIgnoreCase(relation.getRole())) && listOfRelations.stream() .anyMatch(relation -> Constants.ROLE_NEW.equalsIgnoreCase(relation.getRole()))) . . . Read more
Quiero crear un flujo de Lista basado en otro flujo de elementos. El flujo de Lista debe generar una nueva lista cada vez que un elemento de la lista emite un nuevo valor. Algo así: Stream<><modelo>> obtenerFlujoDeLista(List<int> ids) async* { final List<modelo> modelos = []; for (var id in ids) . . . Read more
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 . . . Read more
Después de crear un stream (A), crear otro stream (B) y leer el stream (B), el proceso de lectura se detiene del stream (A). ¿Cómo puedo solucionar este problema? Node.js v14.18.1 import * as readline from ‘readline’; import { Readable } from ‘stream’; async function main() { const streamA = . . . Read more