Package org.reactivestreams.tck

Class SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>

java.lang.Object

org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe<T>

org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>, SubscriberWhiteboxVerification.SubscriberProbe<T>

Enclosing class:

SubscriberWhiteboxVerification<T>

public static class SubscriberWhiteboxVerification.BlackboxSubscriberProxy<T>
extends SubscriberWhiteboxVerification.BlackboxProbe<T>
implements org.reactivestreams.Subscriber<T>

This class is intented to be used as Subscriber decorator and should be used in pub.subscriber(...) calls, in order to allow intercepting calls on the underlying Subscriber. This delegation allows the proxy to implement SubscriberWhiteboxVerification.BlackboxProbe assertions.

Field Summary

Fields inherited from class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

elements, env, error, subscriber

Constructor Summary

Constructors

Constructor	Description
BlackboxSubscriberProxy(TestEnvironment env, org.reactivestreams.Subscriber<T> subscriber)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(java.lang.Throwable cause)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class org.reactivestreams.tck.SubscriberWhiteboxVerification.BlackboxProbe

expectCompletion, expectCompletion, expectCompletion, expectError, expectError, expectError, expectError, expectErrorWithMessage, expectNext, expectNext, expectNext, expectNone, expectNone, registerOnComplete, registerOnError, registerOnNext, sub

Methods inherited from class java.lang.Object

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

Constructor Detail

BlackboxSubscriberProxy

public BlackboxSubscriberProxy(TestEnvironment env,
                               org.reactivestreams.Subscriber<T> subscriber)

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(java.lang.Throwable cause)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>