object AkkaUtil extends HasLoggerName
- Alphabetic
- By Inheritance
- AkkaUtil
- HasLoggerName
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- class CombinedKillSwitch extends KillSwitch
Combines two kill switches into one
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def createActorSystem(namePrefix: String)(implicit ec: ExecutionContext): ActorSystem
Create an Actor system using the existing execution context
ec
- def createExecutionSequencerFactory(namePrefix: String, logger: TracedLogger)(implicit actorSystem: ActorSystem, traceContext: TraceContext): ExecutionSequencerFactory
Create a new execution sequencer factory (mainly used to create a ledger client) with the existing actor system
actorSystem
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContextFromNamedLoggingContext(implicit loggingContext: NamedLoggingContext): ErrorLoggingContext
Convert a com.digitalasset.canton.logging.NamedLoggingContext into an com.digitalasset.canton.logging.ErrorLoggingContext to fix the logger name to the current class name.
Convert a com.digitalasset.canton.logging.NamedLoggingContext into an com.digitalasset.canton.logging.ErrorLoggingContext to fix the logger name to the current class name.
- Attributes
- protected
- Definition Classes
- HasLoggerName
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit def loggerNameFromThisClass: LoggerNameFromClass
- Attributes
- protected
- Definition Classes
- HasLoggerName
- def mapAsyncAndDrainUS[A, Mat, B](source: Source[A, Mat], parallelism: Int)(f: (A) => FutureUnlessShutdown[B])(implicit loggingContext: NamedLoggingContext): Source[B, Mat]
Version of mapAsyncUS that discards the com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdowns.
Version of mapAsyncUS that discards the com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdowns.
Completes when upstream completes and all futures have been completed and all elements have been emitted.
- def mapAsyncUS[A, Mat, B](source: Source[A, Mat], parallelism: Int)(f: (A) => FutureUnlessShutdown[B])(implicit loggingContext: NamedLoggingContext): Source[UnlessShutdown[B], Mat]
Version of akka.stream.scaladsl.FlowOps.mapAsync for a com.digitalasset.canton.lifecycle.FutureUnlessShutdown.
Version of akka.stream.scaladsl.FlowOps.mapAsync for a com.digitalasset.canton.lifecycle.FutureUnlessShutdown. If
f
returns com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown on one element ofsource
, then the returned source returns com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown for all subsequent elements as well.If
parallelism
is one, ensures thatf
is called sequentially for each element ofsource
and thatf
is not invoked on later stream elements iff
returns com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown for an earlier element. Ifparellelism
is greater than one,f
may be invoked on later stream elements even though an earlier invocation results inf
returning com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown.Emits when the Future returned by the provided function finishes for the next element in sequence
Backpressures when the number of futures reaches the configured parallelism and the downstream backpressures or the first future is not completed
Completes when upstream completes and all futures have been completed and all elements have been emitted, including those for which the future did not run due to earlier com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdowns.
Cancels when downstream cancels
- parallelism
The parallelism level. Must be at least 1.
- Exceptions thrown
java.lang.IllegalArgumentException
ifparallelism
is not positive.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def runSupervised[T](reporter: (Throwable) => Unit, graph: RunnableGraph[T], debugLogging: Boolean = false)(implicit mat: Materializer): T
Utility function to run the graph supervised and stop on an unhandled exception.
Utility function to run the graph supervised and stop on an unhandled exception.
By default, an Akka flow will discard exceptions. Use this method to avoid discarding exceptions.
- def statefulMapAsync[Out, Mat, S, T](source: Source[Out, Mat], initial: S)(f: (S, Out) => Future[(S, T)])(implicit loggingContext: NamedLoggingContext): Source[T, Mat]
A version of akka.stream.scaladsl.FlowOps.mapAsync that additionally allows to pass state of type
S
between every subsequent element.A version of akka.stream.scaladsl.FlowOps.mapAsync that additionally allows to pass state of type
S
between every subsequent element. Unlike akka.stream.scaladsl.FlowOps.statefulMapConcat, the state is passed explicitly. Must not be run with supervision strategies akka.stream.Supervision.Restart nor akka.stream.Supervision.Resume - final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])