Package akka.stream.impl.fusing
Class MapAsync.Holder<T>
- java.lang.Object
-
- akka.stream.impl.fusing.MapAsync.Holder<T>
-
-
Constructor Summary
Constructors Constructor Description Holder(scala.util.Try<T> elem, AsyncCallback<MapAsync.Holder<T>> cb)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
apply(scala.util.Try<T> t)
AsyncCallback<MapAsync.Holder<T>>
cb()
scala.util.Try<T>
elem()
void
elem_$eq(scala.util.Try<T> x$1)
void
setElem(scala.util.Try<T> t)
Supervision.Directive
supervisionDirectiveFor(scala.Function1<java.lang.Throwable,Supervision.Directive> decider, java.lang.Throwable ex)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface scala.Function1
andThen, apply$mcDD$sp, apply$mcDF$sp, apply$mcDI$sp, apply$mcDJ$sp, apply$mcFD$sp, apply$mcFF$sp, apply$mcFI$sp, apply$mcFJ$sp, apply$mcID$sp, apply$mcIF$sp, apply$mcII$sp, apply$mcIJ$sp, apply$mcJD$sp, apply$mcJF$sp, apply$mcJI$sp, apply$mcJJ$sp, apply$mcVD$sp, apply$mcVF$sp, apply$mcVI$sp, apply$mcVJ$sp, apply$mcZD$sp, apply$mcZF$sp, apply$mcZI$sp, apply$mcZJ$sp, compose, toString
-
-
-
-
Constructor Detail
-
Holder
public Holder(scala.util.Try<T> elem, AsyncCallback<MapAsync.Holder<T>> cb)
-
-
Method Detail
-
apply
public void apply(scala.util.Try<T> t)
- Specified by:
apply
in interfacescala.Function1<scala.util.Try<T>,scala.runtime.BoxedUnit>
-
cb
public AsyncCallback<MapAsync.Holder<T>> cb()
-
elem
public scala.util.Try<T> elem()
-
elem_$eq
public void elem_$eq(scala.util.Try<T> x$1)
-
setElem
public void setElem(scala.util.Try<T> t)
-
supervisionDirectiveFor
public Supervision.Directive supervisionDirectiveFor(scala.Function1<java.lang.Throwable,Supervision.Directive> decider, java.lang.Throwable ex)
-
-