Я создал функцию расширения,
fun <T> Observable<T>.subscribeWithErrorHandling(onNext: (T) -> Unit ,onError: ((throwable: Throwable) -> Unit)? = null): Subscription {
//doing stuff
}
в классе kotlin я смогу без проблем использовать его таким образом
observable.subscribeWithErrorHandling(...)
Теперь я хочу использовать эту функцию и в своем классе Java. Я уже вижу, что вы можете вызывать его статически, например:
MyExtensionFile.subscribeWithErrorHandling
Но в моем случае вам нужно что-то еще, так как это середина потока RX. И это та часть, с которой я застрял. Это вообще возможно? или нет возможности сделать что-то подобное из java-кода?