akka.stream

Class QueueOfferResult.Failure

java.lang.Object

akka.stream.QueueOfferResult

akka.stream.QueueOfferResult.Failure

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

QueueOfferResult

public static final class QueueOfferResult.Failure
extends QueueOfferResult
implements scala.Product, scala.Serializable

Type is used to indicate that stream is failed before or during call to the stream param: cause - exception that stream failed with

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class akka.stream.QueueOfferResult

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

Constructor Summary

Constructors

Constructor and Description
Failure(java.lang.Throwable cause)

Method Summary

Modifier and Type	Method and Description
java.lang.Throwable	cause()

Methods inherited from class akka.stream.QueueOfferResult

dropped, enqueued

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Failure

public Failure(java.lang.Throwable cause)

Method Detail

cause

public java.lang.Throwable cause()