Dariusz Jędrzejczyk

@patpatpat123 have you tried #3332 which was released in 3.5.7? Are there other operators where you're experiencing backpressure errors?

@stephweiss the backpressure honouring variant was added recently, please check: https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#bufferTimeout-int-java.time.Duration-boolean-

Closing as superseded by #3106

Initial effort to include state machine to processors: #2626

I wouldn't expect this approach to be "safe". For instance, if you call a blocking operator, like `Mono::block()` on a `Scheduler` created this way, it will throw an `IllegalStateException` with...

The last interaction here was over 3 years ago. Closing due to inactivity. Please create a new PR targeting the latest codebase in case you feel this is still applicable.

Closing. This work was superseded by proposal (4) from #3149.

Hey, as I understand, the test uses an unbuffered configuration, which leads to creating a reactor-netty `UdpClient` that polls a provided `Publisher`. The `Publisher` that the [registry provides](https://github.com/micrometer-metrics/micrometer/blob/main/implementations/micrometer-registry-statsd/src/main/java/io/micrometer/statsd/StatsdMeterRegistry.java#L228) is a...

From Reactor's perspective, I think not much can be done, aside from clearing the [ObservationThreadLocalAccessor.KEY](https://github.com/micrometer-metrics/micrometer/blob/f6f8eaed9fe7ff1399964bf85b7b850ad0732187/micrometer-observation/src/main/java/io/micrometer/observation/contextpropagation/ObservationThreadLocalAccessor.java#L33) from the Reactor `Context`, but that doesn't disable the `Observation` that is downstream in the...

Thank you for the report, can you provide a reproducer to help better understand the circumstances when this happens?