Package akka.stream.impl
Class VirtualProcessor.Establishing$
- java.lang.Object
-
- akka.stream.impl.VirtualProcessor.Establishing$
-
- All Implemented Interfaces:
java.io.Serializable
- Enclosing class:
- VirtualProcessor<T>
public static class VirtualProcessor.Establishing$ extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static VirtualProcessor.Establishing$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description Establishing$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
$lessinit$greater$default$2()
OptionVal<java.lang.Throwable>
$lessinit$greater$default$3()
VirtualProcessor.Establishing
apply(org.reactivestreams.Subscriber<java.lang.Object> subscriber, boolean onCompleteBuffered, OptionVal<java.lang.Throwable> onErrorBuffered)
boolean
apply$default$2()
OptionVal<java.lang.Throwable>
apply$default$3()
VirtualProcessor.Establishing
create(org.reactivestreams.Subscriber<?> s)
scala.Option<scala.Tuple3<org.reactivestreams.Subscriber<java.lang.Object>,java.lang.Object,OptionVal<java.lang.Throwable>>>
unapply(VirtualProcessor.Establishing x$0)
-
-
-
Field Detail
-
MODULE$
public static final VirtualProcessor.Establishing$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
$lessinit$greater$default$2
public boolean $lessinit$greater$default$2()
-
$lessinit$greater$default$3
public OptionVal<java.lang.Throwable> $lessinit$greater$default$3()
-
create
public VirtualProcessor.Establishing create(org.reactivestreams.Subscriber<?> s)
-
apply
public VirtualProcessor.Establishing apply(org.reactivestreams.Subscriber<java.lang.Object> subscriber, boolean onCompleteBuffered, OptionVal<java.lang.Throwable> onErrorBuffered)
-
apply$default$2
public boolean apply$default$2()
-
apply$default$3
public OptionVal<java.lang.Throwable> apply$default$3()
-
unapply
public scala.Option<scala.Tuple3<org.reactivestreams.Subscriber<java.lang.Object>,java.lang.Object,OptionVal<java.lang.Throwable>>> unapply(VirtualProcessor.Establishing x$0)
-
-