Upserting with async bucket on java sdk 2.7.15

You can also use one of the blocking operators to wait for the Observable to finish: https://github.com/ReactiveX/RxJava/wiki/Blocking-Observable-Operators.