akka.stream.impl

Class StreamSubscriptionTimeoutSupport.CancelingSubscriber$

java.lang.Object

akka.stream.impl.StreamSubscriptionTimeoutSupport.CancelingSubscriber$

All Implemented Interfaces:

java.io.Serializable, org.reactivestreams.Subscriber<java.lang.Object>, scala.Equals, scala.Product

Enclosing interface:

StreamSubscriptionTimeoutSupport

public static class StreamSubscriptionTimeoutSupport.CancelingSubscriber$
extends java.lang.Object
implements org.reactivestreams.Subscriber<java.lang.Object>, scala.Product, scala.Serializable

A subscriber who calls cancel directly from onSubscribe and ignores all other callbacks.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static StreamSubscriptionTimeoutSupport.CancelingSubscriber$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
CancelingSubscriber$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final StreamSubscriptionTimeoutSupport.CancelingSubscriber$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

CancelingSubscriber$

public CancelingSubscriber$()

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<java.lang.Object>

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<java.lang.Object>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<java.lang.Object>

onNext

public void onNext(java.lang.Object elem)

Specified by:

onNext in interface org.reactivestreams.Subscriber<java.lang.Object>