class MainActivity : AppCompatActivity() {
   private val relay = PublishRelay.create<Int>()
   private var isError: Boolean = false
   override fun onCreate(savedInstanceState: Bundle?) {
       super.onCreate(savedInstanceState)
       setContentView(R.layout.activity_main)
       val disposable1 = relay
           .map {
               if (isError) {
                   isError = false
                   throw Exception()
               } else {
                   isError = true
               }
           }.subscribe(
               {
                   Log.d("test", "Цепочка с ошибкой: onNext")
               },
               {
                   Log.d("test", "Цепочка с ошибкой: onError")
               }
           )
       val disposable2 = relay
           .subscribe(
               {
                   Log.d("test", "Цепочка без ошибки: onNext")
               },
               {
                   Log.d("test", "Цепочка без ошибки: onError")
               }
           )
       btn.setOnClickListener {
           relay.accept(1)
       }
   }
}