Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
El fragmento de código a continuación, a largo plazo, siempre produce un error de Out-Of-Memory, especialmente al leer de un archivo / contenido muy voluminoso. ¿Hay otra forma de volver a escribir esto, especialmente usando streams? Vi una forma de convertir una matriz de bytes en una cadena hexadecimal aquí: . . . Read more
Me gustaría escribir una prueba unitaria para una función generadora, pero no puedo pasar un objeto de flujo de lectura correctamente simulado (ReadStream). Función que se puede probar: public async * readChunks(file: string, chunkSize: number): AsyncIterableIterator<buffer> { if (!this.cwd) throw new Error(‘¡No se ha establecido el directorio de trabajo!’); const . . . Read more
Cuál es la forma idiomática de validar un Source de akka-stream en una prueba unitaria? Estoy haciendo algo así: f.service.fetchData(id).flatMap { case Right(source) => { // TODO: Necesito validar aquí que source contenga “Test value” } case Left(_) => fail(“Respondió incorrectamente con un error”) } El source básicamente es: Source.single(ByteString(“Test . . . Read more
Hoy mi código se volvió loco y escribió en la base de datos de Firestore 1000 veces y leyó alrededor de 50k documentos en cuestión de segundos. Esto se debió a un error al llamar a las operaciones de escritura, lo cual hizo que el flujo de instantáneas de Firebase . . . Read more
Estoy tratando de simular un método que devuelve el tipo: Future[Option[(ContentType, Long, Source[ByteString, NotUsed])]] Lo simulo así: when(service.fetchData(id)).thenReturn(Future.successful( Some((ContentTypes.`application/octet-stream`, 1000, Source("Dummy Byte string"))) ) ) Pero me da un error: value thenReturn is not a member of Nothing when(service.fetchData(id)).thenReturn(Future.successful( No veo ninguna discrepancia entre el valor de retorno simulado y . . . Read more