Sheridan C Rawlins

One of the reasons that I installed UTM is that the experience with X11 is pretty miserable if going through, say a Docker Desktop to XQuartz (the color tables are...

Doing it this way, however, doesn't seem to deal with backpressure… defer is only deferred until subscription - need some way of not invoking the generator until subscribers actually request...

I can take a look at that, but I think changing flatMap to concatMap in my code above did the trick - then the "next" Flowable isn't subscribed to until...

FWiW, expand might work, but unfold is a little more general - and seems to be forming as a pattern in scalaz, scala, akka… https://blog.genuine.com/2020/07/scala-unfold/ Essentially folding is a reduction...

On another note - [Flowable.generate](http://reactivex.io/RxJava/3.x/javadoc/io/reactivex/rxjava3/core/Flowable.html#generate-io.reactivex.rxjava3.functions.Supplier-io.reactivex.rxjava3.functions.BiFunction-) Has a signature that is _VERY_ close to what I need, but… isn't async… if there were some mechanism to workaround the Note non-async note...

OMG - thank you… I hadn't encountered the extensions before… I mean… I know about it now but where is that linked from the main documentation? Also… while this will...

Hmm… that falls short alas… as the state is returned immediately; not as part of the future… Really want the state => Maybe((state, elem)) - i.e. the state is not...

> @scr-oath Akka is not your first choice android because of the package size right? Well, if you're curious yes and no - it's not about "size" exactly but about...

> Do you have an sequence like `state -> item -> state -> item` where each step happens in distinct time? If so, it could be done with a feedback...

This seems to work… with the serialized PublishProcessor - just using doEach rather than map and firing up the seed (and subsequent) in `io` thread… Actually… this does appear simpler...