Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Este código prueba la cancelación de una fibra creada desde un completable future y está fallando: val toCancel = CompletableFuture.supplyAsync { () => Thread.sleep(20000) () } val test = for { foo <- IO.fromCompletableFuture(IO(toCancel)).start _ <- IO.sleep(1.second) _ <- foo.cancel } yield toCancel.isCancelled assertIOBoolean(test) ¿Es esto un bug de Cats . . . Read more
Considera la siguiente secuencia futura: val s1 = Future.sequence((1 to 5).map(someFuncReturningFuture)) Y al final quiero devolver un Future[MyCaseClass], donde MyCaseClass es una clase de tipo case que toma 5 parámetros, los cuales quiero que sean los 5 Int dentro de s1. Pensé que s1.map((a1, a2, a3, a4, a5) => MyCaseClass(a1, . . . Read more
Estoy intentando leer datos de Cloud Firestore (funcionando) y colocar los datos en un ListView que contiene un widget gráfico (Order) que muestra el precio, la fecha y el producto, pero cuando intento devolver los datos desde el método, aparece este error. El objetivo es devolver los datos del usuario . . . Read more
Quiero hacer un programa de prueba con CompletableFuture. Tengo una clase con 2 funciones: public class FutureTextData { private ConcurrentHashMap<String,Integer> map = new ConcurrentHashMap<>(); private CompletableFuture<Void> futureForText; <pre><code>public void getCharInText(String texto){ futureForText = CompletableFuture.runAsync(() -> { for (int i = 0; i < texto.length()-3; i++) { map.compute(texto.substring(i+1),(clave,valor) -> valor+=1); map.compute(texto.substring(i+2),(clave,valor) . . . Read more
Estoy tratando de hacer una solicitud GET y imprimir la respuesta JSON que recibo. La respuesta JSON debería verse así. { “request_status”: “Success”, “workflow_step”: “End” } Aquí está mi código: handle(GetStatus) { args: GetStatus.Args => val client: Service[http.Request, http.Response] = Http.client.withTlsWithoutValidation.newService(“idm-preprod-fe1.twitter.biz:80”) val request = http.Request( http.Method.Get, “/plugin/rest/groupmanagement/getStatus/Create Group Request for . . . Read more