David Karnok

> `compose` You have disconnected output, there is no way to link it to the original inside the operator. > scalar `flatMap` You may have to prevent optimizations by using...

> It can be fixed by adding extra source field I'm not fond of keeping a reference to something otherwise not used. You could use some ThreadLocal trickery to remember...

No single operator but you can achieve it via combination of several: - collect each source into a set - zip these and in the handler, use set1.retainAll(set2); set1.retainAll(set3); return...

@Desislav-Petrov `lazySets` have to be made `getAndSet`: https://github.com/ReactiveX/RxJava/blob/3.x/src/main/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableThrottleLatest.java#L130

Az +++ lényege, hogy kimaxolja a felszerelést. Mivel nem lehet mixelni, ezért ha nem veszi le, nem lehet újabbal feltölteni a slotot. A megoldás: többet kell gyártani. Ha megnyomod a...

I started getting this with Planet Crafter private beta. - 682 worked with 2023.1.9f1 - 682 doesn't work with 2023.2.4f1 *BepInEx-Unity.IL2CPP-win-x64-6.0.0-be.682+910844a.zip*

I welcome the use of standard Reactive-Streams APIs and let the client wrap their rich fluent APIs of choice around a `Publisher`. However, targeting reactive streams directly exposes you to...

Does `tailer.readDocument` returning false indicate an end of data or a temporary lack of data? For the former case, you can adapt `fromIterable` from our libraries. The latter case is...

Because of the `flatMap` with maxConcurrency = 1 and the inherent preference towards last sender in `flatMap`, each time one group item is processed, it requests, 1 more item that...

> Do I understand you correctly that concurrency limit on inner flatmap can affect mapping of groups? (.flatMap(grouped ) Concurrency limit can result in skewed request patterns, thus it can...