create

@Contract(value = "_ -> new")
open fun <T> create(@NonNull emitter: Consumer<ObservableFuture.Emitter<T>>): ObservableFuture<T>