io.micronaut.tracing.brave.instrument.http

Class HttpServerTracingCorePublisher

java.lang.Object

io.micronaut.tracing.brave.instrument.http.HttpServerTracingPublisher

io.micronaut.tracing.brave.instrument.http.HttpServerTracingCorePublisher

All Implemented Interfaces:

io.micronaut.core.async.publisher.Publishers.MicronautPublisher<io.micronaut.http.MutableHttpResponse<?>>, org.reactivestreams.Publisher<io.micronaut.http.MutableHttpResponse<?>>, reactor.core.CorePublisher<io.micronaut.http.MutableHttpResponse<?>>

public class HttpServerTracingCorePublisher
extends HttpServerTracingPublisher
implements reactor.core.CorePublisher<io.micronaut.http.MutableHttpResponse<?>>

Handles HTTP client server tracing.

Since:

4.1.0

Author:

Nemanja Mikic

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.tracing.brave.instrument.http.HttpServerTracingPublisher

HttpServerTracingPublisher.TracingSubscriber

Field Summary

Fields inherited from class io.micronaut.tracing.brave.instrument.http.HttpServerTracingPublisher

publisher

Method Summary

Modifier and Type	Method and Description
protected void	doSubscribe(brave.Span span, org.reactivestreams.Subscriber<? super io.micronaut.http.MutableHttpResponse<?>> actual) Do subscribe to the publisher.
void	subscribe(reactor.core.CoreSubscriber<? super io.micronaut.http.MutableHttpResponse<?>> subscriber)

Methods inherited from class io.micronaut.tracing.brave.instrument.http.HttpServerTracingPublisher

subscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

subscribe

public void subscribe(reactor.core.CoreSubscriber<? super io.micronaut.http.MutableHttpResponse<?>> subscriber)

Specified by:

subscribe in interface reactor.core.CorePublisher<io.micronaut.http.MutableHttpResponse<?>>

doSubscribe

protected void doSubscribe(brave.Span span,
                           org.reactivestreams.Subscriber<? super io.micronaut.http.MutableHttpResponse<?>> actual)

Description copied from class: HttpServerTracingPublisher

Do subscribe to the publisher.

Overrides:

doSubscribe in class HttpServerTracingPublisher

Parameters:

span - The span

actual - The actual subscriber