CancelledSubscriber

java.lang.Object

org.playframework.netty.CancelledSubscriber<T>

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

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

A cancelled subscriber.

Constructor Summary

Constructors

Constructor

Description

CancelledSubscriber()
Method Summary

Modifier and Type

Method

Description

void

onComplete()

void

onError(Throwable error)

void

onNext(T t)

void

onSubscribe(org.reactivestreams.Subscription subscription)

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

Constructor Details
- CancelledSubscriber
  
  public CancelledSubscriber()
Method Details
- onSubscribe
  
  public void onSubscribe(org.reactivestreams.Subscription subscription)
  
  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(Throwable error)
  
  Specified by:
  
  onError in interface org.reactivestreams.Subscriber<T>
- onComplete
  
  public void onComplete()
  
  Specified by:
  
  onComplete in interface org.reactivestreams.Subscriber<T>