io.micronaut.tracing.brave.instrument.http

Class HttpServerTracingPublisher.TracingSubscriber

java.lang.Object

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

All Implemented Interfaces:

org.reactivestreams.Subscriber<io.micronaut.http.MutableHttpResponse<?>>

Enclosing class:

HttpServerTracingPublisher

protected class HttpServerTracingPublisher.TracingSubscriber
extends java.lang.Object
implements org.reactivestreams.Subscriber<io.micronaut.http.MutableHttpResponse<?>>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TracingSubscriber(brave.Span span, org.reactivestreams.Subscriber<? super io.micronaut.http.MutableHttpResponse<?>> actual)

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onError(java.lang.Throwable error)
void	onNext(io.micronaut.http.MutableHttpResponse<?> response)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

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

Constructor Detail

TracingSubscriber

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

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<io.micronaut.http.MutableHttpResponse<?>>

onNext

public void onNext(io.micronaut.http.MutableHttpResponse<?> response)

Specified by:

onNext in interface org.reactivestreams.Subscriber<io.micronaut.http.MutableHttpResponse<?>>

onError

public void onError(java.lang.Throwable error)

Specified by:

onError in interface org.reactivestreams.Subscriber<io.micronaut.http.MutableHttpResponse<?>>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<io.micronaut.http.MutableHttpResponse<?>>