akka.stream.impl

Class FanIn.SubInput<T>

java.lang.Object

akka.stream.impl.FanIn.SubInput<T>

All Implemented Interfaces:

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

Enclosing class:

FanIn

public static final class FanIn.SubInput<T>
extends java.lang.Object
implements org.reactivestreams.Subscriber<T>, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SubInput(ActorRef impl, int id)

Method Summary

Modifier and Type	Method and Description
int	id()
ActorRef	impl()
void	onComplete()
void	onError(java.lang.Throwable cause)
void	onNext(T element)
void	onSubscribe(org.reactivestreams.Subscription subscription)

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

Constructor Detail

SubInput

public SubInput(ActorRef impl,
                int id)

Method Detail

impl

public ActorRef impl()

id

public int id()

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>

onNext

public void onNext(T element)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>