akka.stream.scaladsl

Class MergeHub.InputState

java.lang.Object

akka.stream.scaladsl.MergeHub.InputState

Enclosing class:

MergeHub<T>

public final class MergeHub.InputState
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
InputState(AsyncCallback<java.lang.Object> signalDemand)

Method Summary

Modifier and Type	Method and Description
void	close()
void	onElement()

Methods inherited from class java.lang.Object

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

Constructor Detail

InputState

public InputState(AsyncCallback<java.lang.Object> signalDemand)

Method Detail

onElement

public void onElement()

close

public void close()