线程bug about rxwebsocket HOT 6 CLOSED

    var observable: Observable<Int>? = null
    fun getMyObservable(): Observable<Int> {
        if (observable == null) {
            observable = Observable.just(1).observeOn(Schedulers.io())
        } else {
            observable = observable!!.startWith(2)
        }
        return observable!!
    }

    @Test
    fun rxjavaTest() {
        Observable.just(Unit)
                .observeOn(Schedulers.computation())
                .subscribe { _ ->
                    getMyObservable()
                            .subscribe {
                                println("first got data $it ${Thread.currentThread().name}")
                            }
                    getMyObservable()
                            .subscribe { d ->
                                println("second got data $d ${Thread.currentThread().name}")
                            }
                }
        Thread.sleep(10 * 1000)
    }