akka.stream.impl

Class FanOut.SubstreamSubscription

java.lang.Object

akka.stream.impl.FanOut.SubstreamSubscription

All Implemented Interfaces:

org.reactivestreams.Subscription

Enclosing class:

FanOut

public static class FanOut.SubstreamSubscription
extends java.lang.Object
implements org.reactivestreams.Subscription

Constructor Summary

Constructors

Constructor and Description
SubstreamSubscription(ActorRef parent, int id)

Method Summary

Modifier and Type	Method and Description
void	cancel()
int	id()
ActorRef	parent()
void	request(long elements)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SubstreamSubscription

public SubstreamSubscription(ActorRef parent,
                             int id)

Method Detail

parent

public ActorRef parent()

id

public int id()

request

public void request(long elements)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object