I ended up writing this:

# reaktive

[saket]

I ended up writing this:

[Arkadii Ivanov]

Hello!

observableUnsafe {} is equivalent to RxJava's Observable.unsafeCreate {} , whereas observable {} is equivalent to RxJava's Observable.create {} .
So basically you can write something like this:

observable<String> { emitter ->
        emitter.setDisposable(Disposable {  })
    }

You can also define the following extension for convenience:

inline fun Emitter.setCancellable(crossinline cancellable: () -> Unit) {
    setDisposable(Disposable(cancellable))
}

[Arkadii Ivanov]

I raised an issue to add this to the library, feel free to PR: https://github.com/badoo/Reaktive/issues/489

[saket]

unthreading for visibility to others

[saket]

I was trying to search for observableCreate. Took me some time to notice observable {}.