Rxjava - ¿Puedo invocar el método `Subject.onNext` desde diferentes hilos?

No directamente. Debe proporcionar la serialización de alguna manera o utilizar el toSerialized()método y comunicarse con la Subject<T, R>instancia devuelta .

PublishSubject<Integer> ps = PublishSubject.create();

Subject<Integer, Integer> subject = ps.toSerialized();

subject.subscribe(System.out::println);

subject.onNext(1);
Respuesta 1

Estoy tratando de crear el número 0.00000 .... con tantos '0' como quiera la entrada del usuario. ¿Qué hay de malo con mi código a continuación? int n; doble dec = 0.0; in = nuevo escáner (System.in); ...

Estoy usando Spring con JPA (Hibernate). Como estaba aprendiendo de muchos sitios sobre relaciones (hay pocas formas de implementar cada uno de ellos) también se habló sobre buscar tipos, pero la pregunta I ...

Actualmente estoy escribiendo una clase que crea múltiples manos que contienen objetos de tarjeta usando arrayLists. Estoy tratando de escribir un método que busque una lista de matrices (mano) y devuelva el par más grande de ...

Estoy tratando de hacer un clon de AsyncTask de Android para usar en una aplicación JavaFX. Aquí está el código que se me ocurrió: import java.util.concurrent.Executor; import java.util.concurrent.Executors; resumen ...