akka.stream.impl.fusing

Class SubSink.CommandScheduledBeforeMaterialization

java.lang.Object

akka.stream.impl.fusing.SubSink.CommandScheduledBeforeMaterialization

All Implemented Interfaces:

SubSink.State

Direct Known Subclasses:

SubSink.CancelScheduledBeforeMaterialization$, SubSink.RequestOneScheduledBeforeMaterialization$

Enclosing class:

SubSink<T>

public abstract static class SubSink.CommandScheduledBeforeMaterialization
extends java.lang.Object
implements SubSink.State

A command was scheduled before materialization

Constructor Summary

Constructors

Constructor and Description
CommandScheduledBeforeMaterialization(SubSink.Command command)

Method Summary

Modifier and Type	Method and Description
SubSink.Command	command()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandScheduledBeforeMaterialization

public CommandScheduledBeforeMaterialization(SubSink.Command command)

Method Detail

command

public SubSink.Command command()