SubscriberWrapper (javaagent 2.0.0-alpha API)

java.lang.Object

io.opentelemetry.javaagent.instrumentation.armeria.v1_3.SubscriberWrapper<T>

All Implemented Interfaces:: org.reactivestreams.Subscriber<T>

public class SubscriberWrapper<T> extends Object implements org.reactivestreams.Subscriber<T>

Method Summary

Modifier and Type

Method

Description

void

onComplete()

void

onError(Throwable throwable)

void

onNext(T o)

void

onSubscribe(org.reactivestreams.Subscription subscription)

static <T> org.reactivestreams.Subscriber<T>

wrap(org.reactivestreams.Subscriber<T> delegate)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- wrap
  
  public static <T> org.reactivestreams.Subscriber<T> wrap(org.reactivestreams.Subscriber<T> delegate)
- onSubscribe
  
  public void onSubscribe(org.reactivestreams.Subscription subscription)
  
  Specified by:
  
  onSubscribe in interface org.reactivestreams.Subscriber<T>
- onNext
  
  public void onNext(T o)
  
  Specified by:
  
  onNext in interface org.reactivestreams.Subscriber<T>
- onError
  
  public void onError(Throwable throwable)
  
  Specified by:
  
  onError in interface org.reactivestreams.Subscriber<T>
- onComplete
  
  public void onComplete()
  
  Specified by:
  
  onComplete in interface org.reactivestreams.Subscriber<T>