### Question:
TraceableSubscriptionQueryResult implements SubscriptionQueryResult<I, U> { public TraceableSubscriptionQueryResult(SubscriptionQueryResult<I, U> subscriptionQueryResult, Span span) { this.initialResult = subscriptionQueryResult.initialResult(); this.updates = subscriptionQueryResult.updates(); this.registrationDelegate = subscriptionQueryResult; this.span = span; } TraceableSubscriptionQueryResult(SubscriptionQueryResult<I, U> subscriptionQueryResult, Span span); @Override Mono<I> initialResult(); @Override Flux<U> updates(); @Override boolean cancel();  }### Answer:
@Test void testTraceableSubscriptionQueryResult() { Mono<String> initialResult = Mono.just("initial"); Flux<String> updates = Flux.just("update1", "update2"); SubscriptionQueryResult<String, String> subscriptionQueryResult = new DefaultSubscriptionQueryResult<>(initialResult, updates, () -> true); Span span = mockTracer.buildSpan("test").start(); TraceableSubscriptionQueryResult<String, String> traceableSubscriptionQueryResult = new TraceableSubscriptionQueryResult<>(subscriptionQueryResult, span); StepVerifier.create(traceableSubscriptionQueryResult.initialResult()) .expectNext("initial") .expectComplete() .verify(); StepVerifier.create(traceableSubscriptionQueryResult.updates()) .expectNext("update1") .expectNext("update2") .expectComplete() .verify(); }