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 elementstatic 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 withstatic class
QueueOfferResult.Failure$
static class
QueueOfferResult.QueueClosed$
-
Constructor Summary
Constructors Constructor Description QueueOfferResult()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static QueueOfferResult
dropped()
static QueueOfferResult
enqueued()
-
-
-
Method Detail
-
enqueued
public static QueueOfferResult enqueued()
-
dropped
public static QueueOfferResult dropped()
-
-