Package 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	Description
static class	QueueOfferResult.Dropped$	Type is used to indicate that stream is dropped an element
static class	QueueOfferResult.Enqueued$
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$

Constructor Summary

Constructors

Constructor	Description
QueueOfferResult()

Method Summary

Modifier and Type	Method	Description
static QueueOfferResult	dropped()
static QueueOfferResult	enqueued()

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()

dropped

public static QueueOfferResult dropped()