Package org.apache.pekko.stream.testkit
Class StreamTestKit.FailedSubscription$
java.lang.Object
org.apache.pekko.stream.testkit.StreamTestKit.FailedSubscription$
- All Implemented Interfaces:
Serializable
- Enclosing class:
- StreamTestKit
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StreamTestKit.FailedSubscription$Static reference to the singleton instance of this Scala object. -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Constructor Details
-
FailedSubscription$
public FailedSubscription$()
-
-
Method Details
-
toString
-
apply
public <T> StreamTestKit.FailedSubscription<T> apply(org.reactivestreams.Subscriber<T> subscriber, Throwable cause) -
unapply
public <T> scala.Option<scala.Tuple2<org.reactivestreams.Subscriber<T>,Throwable>> unapply(StreamTestKit.FailedSubscription<T> x$0)
-