Dariusz Jędrzejczyk

As explained in https://github.com/micrometer-metrics/context-propagation/issues/295#issuecomment-2388988545 `Observation` is a specific user of the context-propagation library and should not delegate to its generic capabilities for the purpose of propagating a specific state. I...

Hey, thanks for the report. I am wondering though - aren't you explicitly swallowing the error with `.onErrorResume(e -> Mono.empty())` that follows after the `.collectList()` operator?

*[EDIT]* I misinterpreted the sequence of events in my initial evaluation. The below is not really what's going on since the delay is applied to a successful termination of a...

My apologies, I think I have confused something there. Your questions are very helpful and I do think you might have in fact discovered a bug that's a race condition...

Just for the record - the exclusivity of drain looks correct, so not both threads are draining at the same time. My observation came from the natural concurrency in `Flux.flatMap`...

Hey, thanks! Would you be interested in opening a PR to address this?

@christophstrobl Hey, only now I just found the time to look into this, so it looks I'm late to the party. However, from the vague understanding that I seem to...

Thanks for the report. It somehow wasn't noticed, apologies. This I believe is a known issue with late subscribers. I'll try to summarize some similar reports and try to keep...

Hey, @mipo256. Thank you for the suggestion. I am wondering whether you tried [`recordWith`](https://projectreactor.io/docs/test/release/api/reactor/test/StepVerifier.Step.html#recordWith-java.util.function.Supplier-) along with [`consumeRecordedWith`](https://projectreactor.io/docs/test/release/api/reactor/test/StepVerifier.Step.html#consumeRecordedWith-java.util.function.Consumer-) - I think it would satisfy your needs. Is there something you can't...

I think the question with your proposal is - what happens after N? We do have exactly a mechanism for this scenario and it's the `recordWith` pattern. Please have a...