setChanged();<br /> notifyObservers(object_to_send_to_observer);

setChanged();<br /> notifyObservers(object_that_u_want_to_send_to_Observer);

class ObservableAndObserver {</p> <p> public static void main(String[] args) {</p> <p> Observable<Integer> source = new ObservableCreate<Integer>(new ObservableOnSubscribe<Integer>() {</p> <p> @Override<br /> public void subscribe(@NonNull ObservableEmitter<Integer> emitter) throws Throwable {<br /> try {<br /> emitter.onNext(10);<br /> emitter.onNext(11);<br /> emitter.onComplete();<br /> }catch(Throwable t) {<br /> emitter.onError(t);<br /> }</p> <p> }<br /> });</p> <p> Observer<Integer> observer = new Observer<Integer>() {</p> <p> @Override<br /> public void onSubscribe(@NonNull Disposable d) {<br /> System.out.println(” Subscribed “);</p> <p> }</p> <p> @Override<br /> public void onNext(@NonNull Integer t) {<br /> System.out.println(“On Next : ” + t);</p> <p> }</p> <p> @Override<br /> public void onError(@NonNull Throwable e) {<br /> e.printStackTrace();</p> <p> }</p> <p> @Override<br /> public void onComplete() {<br /> System.out.println(“Completed !”);</p> <p> }<br /> };</p> <p> source.subscribe(observer);</p> <p> }</p> <p>}<br />