reactivex java 미래의 임의의 시간에 이벤트를 방출하는 사용자 정의 관찰자 만들기

Question

observable 및 subscriber 목록을 다시 작성하지 않고 나중에 비동기 관찰자 및 trigger/emit 이벤트를 만드는 방법을 알아 내려고합니다. ; MyAsyncObservable 단지가 될 수

MyAsyncObservable o = new MyAsyncObservable(); 

o.subscribe(s); 
o.subscribe(s2); 
while(scanner.hasNext()){ 
    o.emit(scanner.nextInt()); // emit T to subscribers. 
} 

Observable.fromAsync(emitter,buffermode)

대신

while(scanner.hasNext(){ 
    Observable<Integer> o = Observable.just(scanner.nextInt()); 
    o.subscribe(s); 
    o.subscribe(s2); 
} 

Answer 1

경우, 단지) (차가운 .delay 사용되는 관찰 :

같은 뭔가를 찾고 f.e.를 참조하십시오. 이 :

Observable.just("Hello!").delay(10, TimeUnit.SECONDS).subscribe(System.out::println); 

이 뜨거운 관찰 할 수 있다면, 당신이 10 초 안에 10 명 이상의 배출을 기대하지 않는 가정 버퍼를 (추가 :

Observable 
    .just("Hello!") 
    .onBackpressureBuffer(10) 
    .delay(10, TimeUnit.SECONDS) 
    .subscribe(System.out::println); 

편집 : 아, 그렇군요 - 당신이 원하는 Subject -. PublishSubject 또는 BehaviorSubject 어느 그들을 만들고 통해 그들에게 데이터를 공급 일반적인 onNext/onComplete를 /의 OnError