-
Notifications
You must be signed in to change notification settings - Fork 57
Description
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.