Я использую оператор .debounce в rxjava / rxscala для захвата некоторых событий, которые происходят...

У меня сейчас есть следующий код: def method(): Future[State] = Future { // some processing State

Я новичок в RxScala Observables и испытываю странное поведение при использовании комбинации take...