akka.stream.impl.fusing

Class ActorGraphInterpreter.BoundarySubscription

java.lang.Object

akka.stream.impl.fusing.ActorGraphInterpreter.BoundarySubscription

All Implemented Interfaces:

org.reactivestreams.Subscription

Enclosing class:

ActorGraphInterpreter

public static final class ActorGraphInterpreter.BoundarySubscription
extends java.lang.Object
implements org.reactivestreams.Subscription

Constructor Summary

Constructors

Constructor and Description
BoundarySubscription(ActorRef parent, GraphInterpreterShell shell, int id)

Method Summary

Modifier and Type	Method and Description
void	cancel()
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

BoundarySubscription

public BoundarySubscription(ActorRef parent,
                            GraphInterpreterShell shell,
                            int id)

Method Detail

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