akka.stream

Class QueueOfferResult

java.lang.Object

akka.stream.QueueOfferResult

Direct Known Subclasses:

QueueOfferResult.Dropped$, QueueOfferResult.Enqueued$, QueueOfferResult.Failure, QueueOfferResult.QueueClosed$

public abstract class QueueOfferResult
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueueOfferResult.Dropped$ Type is used to indicate that stream is dropped an element
static class	QueueOfferResult.Enqueued$ Type is used to indicate that stream is successfully enqueued an element
static class	QueueOfferResult.Failure Type is used to indicate that stream is failed before or during call to the stream param: cause - exception that stream failed with
static class	QueueOfferResult.Failure$
static class	QueueOfferResult.QueueClosed$ Type is used to indicate that stream is completed before call

Constructor Summary

Constructors

Constructor and Description
QueueOfferResult()

Method Summary

Modifier and Type	Method and Description
static QueueOfferResult	dropped() Java API: The Enqueued singleton instance
static QueueOfferResult	enqueued() Java API: The Enqueued singleton instance

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueOfferResult

public QueueOfferResult()

Method Detail

enqueued

public static QueueOfferResult enqueued()

Java API: The Enqueued singleton instance

Returns:

(undocumented)

dropped

public static QueueOfferResult dropped()

Java API: The Enqueued singleton instance

Returns:

(undocumented)