hi guys. I am newbie on RxKotlin. Can I remove que...

# rx

[Jazz]

hi guys. I am newbie on RxKotlin. Can I remove queue ?

subject.subscribe{ 
  when(type) {
      A -> {}
      B -> {}
      C -> {}
  }
}

subject.onNext(A)
// queue  [A]
subject.onNext(B)
// queue  [A, B]
subject.onNext(C)
// queue [C]

I want to modify subject stream(modify queue) like android mesage queue (add, remove…)