1 /* 2 * Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. 3 */ 4 5 // This file was automatically generated from coroutines-guide-reactive.md by Knit tool. Do not edit. 6 package kotlinx.coroutines.rx2.guide.basic06 7 8 import io.reactivex.subjects.BehaviorSubject 9 mainnull10fun main() { 11 val subject = BehaviorSubject.create<String>() 12 subject.onNext("one") 13 subject.onNext("two") // updates the state of BehaviorSubject, "one" value is lost 14 // now subscribe to this subject and print everything 15 subject.subscribe(System.out::println) 16 subject.onNext("three") 17 subject.onNext("four") 18 } 19