RxScala, birden fazla Gözlemci ile abone olmak için sadece bir tane yayınlayın.

Question

Çoklu Observer'u kullanmayı denedim , bir döngü içinde onNext meydana geldi. Her bir Gözlemci için işe yaramaz. Sadece ikinci bir abone alamaz Neden ilk Observer

first observer - hi~ 
first observer - hi~ 
... 

için

import rx.lang.scala.Observable 

object SubscribeMultiEvent extends App{ 
    val obv = Observable.apply[String]{ s => 
    def printForever: Unit = { 
     s.onNext("hi~") 
     Thread.sleep(1000) 
     printForever 
    } 
    printForever 
    } 

    obv.subscribe(s => println(s"first observer - $s")) 
    obv.subscribe(s => println(s"second observer - $s")) 

    Thread.currentThread().join() 
} 

Tepki?

Answer 1

Kodlarınızdaki kodunuz Observable senkronize. Bu, ikinci subscribe ilk subscribe bitirene kadar çalışmayacağı anlamına gelir. Ve Observable'unuz hiçbir zaman tamamlanmadığından, ikinci subscribe çalışmayacak.

Bu sorunu gidermek için, Observable saatini asenkronize etmeniz gerekir. Başka bir Konuda çalışmak için subscribeOn'u kullanabilirsiniz. Ör sonunda

import rx.lang.scala.Observable 
import rx.lang.scala.schedulers.NewThreadScheduler 

object SubscribeMultiEvent extends App{ 
    val obv = Observable.apply[String]{ s => 
    def printForever: Unit = { 
     s.onNext("hi~") 
     Thread.sleep(1000) 
     printForever 
    } 
    printForever 
    }.subscribeOn(NewThreadScheduler()) 

    obv.subscribe(s => println(s"first observer - $s")) 
    obv.subscribe(s => println(s"second observer - $s")) 

    Thread.sleep(60000) 
} 

Thread.sleep(60000) önemlidir. RxJava'nın Konuları varsayılan olarak daemon'dur ve ana iş parçacığı bittiğinde, daha fazla daemon olmayan iş parçacığı olmadığı için, JVM çıkacaktır. Ana iş parçacığının durmasını önlemek için Thread.sleep(60000) gibi bir şey eklemeniz gerekir.