Как отменить отображение Observable с указанием условия в RxScala/Java?

исходная наблюдаемая ------a-------b-------c----------d-------->....< br> отображаемый наблюдаемый -----A-------B(finish)
Простой код:

  val original = Observable.just('a', 'b', 'c', 'd')
  val mapped = original.map(x => x.toUpper)
  //how to let `mapped` Observable stop emit event when received 'b' from original?
  //do something
  mapped.subscribe(x => println(x)) //make it only print A ,B

Как сделать отображаемый наблюдаемым завершенным в B этом указанном условии?

ОБНОВЛЕНИЕ для метода takeUntil
takeUntil кажется стандартным ответом, но мой редактор показывает, что этот метод принимает Observable[Any] в качестве параметра. См. определение, пожалуйста,
def takeUntil(that: Observable[Any]): Observable[T]

если я использую следующий код

  val original = Observable.just('a', 'b', 'c', 'd').takeUntil(x => x == 'b')

произошла ошибка компиляции

Error:(74, 64) missing parameter type
  val original = Observable.just('a', 'b', 'c', 'd').takeUntil(x => x == 'b')
                                                           ^

Используем ли мы один и тот же пакет? моя зависимость sbt "com.netflix.rxjava" % "rxjava-scala" % "0.20.7"