Completable.fromSingle(...single<completable> here...)then it the completable call is ignored.
singleAPi.flatmapCompletable(result -> completableAPI(result)), I am able to get an object of type
Completablebut the inner call happens on the main thread even if i do
RxJava2CallAdapterFactory.createWithScheduler(io())call, that assert that all request call are evaluated in the io scheduler
var first = stream.firstOrError()and
var rest = stream.skip(1). Then I do
first.map(f -> someFunction(f, rest)). But when the first is done with that first element it cancels the rest of the
streamwhich seems to hang up on
rest. This is when using
reactive-grpc... (I don't seem to be able to reproduce it using
Flowable.justtype tests even though cancel is called inside rxjava). is there a way to multiplex a stream like this?