Kotlin wrapper example

ServiceImpl.kt

private fun wrap<T>(listener: (ISyncService) -> Observable<T>): Observable<T> {
  val subject: PublishSubject<T> = PublishSubject.create()

  val combo = syncServiceSubject.subscribe({ service ->
      try {
          listener(service).subscribe { result ->
              subject.onNext(result)
          }
      } catch (e: RemoteException) {
          subject.onError(e)
      }
  }, { throwable ->
      subject.onError(throwable)
  })

  compositeSubscription.add(combo)

  return subject.asObservable()
}

override fun signin(phone: String, password: String): Observable<Token> {
  return wrap { service ->
      service.signin(phone, password)
  }
}