Hey team! We've recently stumbled on a bit of a contrived bug in this library when using it with Webflux.
We are subscribing to a Flux. This Flux makes requests to a paged API. Each element emitted by the Flux is a response (page).
In our situation, we'd like to perform a one-time action on the first page. We achieved this using take. When calling take(1) on the Flux, a "complete" event is fired for the first element emitted by the flux, which is captured in the TracingClientResponseSubscriber onComplete handler here. Shortly afterwards, however, a cancel event is fired for the Flux (this is the behavior of take). This cancel event is picked up in the TracingClientResponseSubscriber subscription here.
The end result is that the span is "finished" twice, and a warning is logged.
Expected Behavior
Span is only finished once
Actual Behavior
Spans are finished twice when using the take API- once during a complete event, and again when a cancel event is fired. When using the Flux.take API, a cancel event can follow a complete event.
The work around currently is to not use take() or anything that will emit a complete event followed by a cancel event.
Hey team! We've recently stumbled on a bit of a contrived bug in this library when using it with Webflux.
We are subscribing to a Flux. This Flux makes requests to a paged API. Each element emitted by the Flux is a response (page).
In our situation, we'd like to perform a one-time action on the first page. We achieved this using
take. When callingtake(1)on the Flux, a "complete" event is fired for the first element emitted by the flux, which is captured in theTracingClientResponseSubscriberonCompletehandler here. Shortly afterwards, however, a cancel event is fired for the Flux (this is the behavior oftake). This cancel event is picked up in theTracingClientResponseSubscribersubscription here.The end result is that the span is "finished" twice, and a warning is logged.
Expected Behavior
Span is only
finished onceActual Behavior
Spans are
finished twice when using thetakeAPI- once during a complete event, and again when a cancel event is fired. When using theFlux.takeAPI, a cancel event can follow a complete event.The work around currently is to not use
take()or anything that will emit a complete event followed by a cancel event.