class SequencerBenchmark extends HasExecutorServiceGeneric with TestEssentials with FlagCloseable with HasCloseContext
- Annotations
- @SuppressWarnings() @State() @Warmup() @Measurement() @Fork()
- Alphabetic
- By Inheritance
- SequencerBenchmark
- HasCloseContext
- PromiseUnlessShutdownFactory
- FlagCloseable
- PerformUnlessClosing
- HasSynchronizeWithReaders
- OnShutdownRunner
- HasRunOnClosing
- HasUnlessClosing
- AutoCloseable
- TestEssentials
- ArgumentMatchersSugar
- MacroBasedMatchers
- NumericMatchers
- Tolerance
- FunctionMatchers
- NullMatchers
- StringThatMatchers
- ThatMatchers
- EqMatchers_VersionSpecific
- EqMatchers
- AnyMatchers
- MockitoSugar
- ScalacticSerialisableHack
- Rest
- Verifications
- DoSomething
- MockitoEnhancer
- MockCreator
- ScalaFuturesWithPatience
- ScalaFutures
- Futures
- PatienceConfiguration
- AbstractPatienceConfiguration
- ScaledTimeSpans
- HasExecutorServiceGeneric
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SequencerBenchmark()
Type Members
- class Env extends AutoCloseable with NamedLogging
- Annotations
- @SuppressWarnings()
- trait FutureConcept[T] extends AnyRef
- Definition Classes
- Futures
- final case class PatienceConfig extends Product with Serializable
- Definition Classes
- AbstractPatienceConfiguration
- final class PlusOrMinusWrapper[T] extends AnyRef
- Definition Classes
- Tolerance
- case class ReadState(memberId: SequencerMemberId, member: Member, nextReadTimestamp: CantonTimestamp, lastBatchWasFull: Boolean = false) extends Product with Serializable
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def *[T](implicit default: DefaultValueProvider[T]): T
- Definition Classes
- MacroBasedMatchers
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addReader(reader: String)(implicit traceContext: TraceContext): UnlessShutdown[ReaderHandle]
TODO(#16601) Make this method private once PerformUnlessClosing doesn't need it any more
TODO(#16601) Make this method private once PerformUnlessClosing doesn't need it any more
- Attributes
- protected[this]
- Definition Classes
- HasSynchronizeWithReaders
- def after(millis: Int): VerificationAfterDelay
- Definition Classes
- Verifications
- def any[T](implicit default: DefaultValueProvider[T]): T
- Definition Classes
- MacroBasedMatchers
- def anyBoolean: Boolean
- Definition Classes
- AnyMatchers
- def anyByte: Byte
- Definition Classes
- AnyMatchers
- def anyChar: Char
- Definition Classes
- AnyMatchers
- def anyDouble: Double
- Definition Classes
- AnyMatchers
- def anyFloat: Float
- Definition Classes
- AnyMatchers
- def anyInt: Int
- Definition Classes
- AnyMatchers
- def anyIterable[T]: Iterable[T]
- Definition Classes
- AnyMatchers
- def anyList[T]: List[T]
- Definition Classes
- AnyMatchers
- def anyLong: Long
- Definition Classes
- AnyMatchers
- def anyMap[K, V]: Map[K, V]
- Definition Classes
- AnyMatchers
- def anySeq[T]: Seq[T]
- Definition Classes
- AnyMatchers
- def anySet[T]: Set[T]
- Definition Classes
- AnyMatchers
- def anyShort: Short
- Definition Classes
- AnyMatchers
- def anyTraceContext: TraceContext
- Definition Classes
- TestEssentials
- def argMatching[T](pf: PartialFunction[Any, Unit]): T
- Definition Classes
- ThatMatchers
- def argThat[T](f: (T) => Boolean, desc: => String): T
- Definition Classes
- ThatMatchers
- def argThat[T](matcher: ArgumentMatcher[T]): T
- Definition Classes
- ThatMatchers
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def atLeast(minNumberOfInvocations: Int): VerificationMode
- Definition Classes
- Verifications
- def atLeastOnce: VerificationMode
- Definition Classes
- Verifications
- def atMost(maxNumberOfInvocations: Int): VerificationMode
- Definition Classes
- Verifications
- def booleanThat(matcher: ArgumentMatcher[Boolean]): Boolean
- Definition Classes
- ThatMatchers
- def byteThat(matcher: ArgumentMatcher[Byte]): Byte
- Definition Classes
- ThatMatchers
- def calls(wantedNumberOfInvocations: Int): VerificationMode
- Definition Classes
- Verifications
- def charThat(matcher: ArgumentMatcher[Char]): Char
- Definition Classes
- ThatMatchers
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def close(): Unit
Blocks until all earlier tasks have completed and then prevents further tasks from being run.
Blocks until all earlier tasks have completed and then prevents further tasks from being run.
- Definition Classes
- FlagCloseable → OnShutdownRunner → AutoCloseable
- implicit val closeContext: CloseContext
- Definition Classes
- HasCloseContext
- def closeExecutor(): Unit
- Attributes
- protected
- Definition Classes
- HasExecutorServiceGeneric
- def closingTimeout: FiniteDuration
- Attributes
- protected
- Definition Classes
- FlagCloseable → PerformUnlessClosing
- def contains(substring: String): String
- Definition Classes
- StringThatMatchers
- implicit def convertNumericToPlusOrMinusWrapper[T](pivot: T)(implicit arg0: Numeric[T]): PlusOrMinusWrapper[T]
- Definition Classes
- Tolerance
- implicit def convertScalaFuture[T](scalaFuture: Future[T]): FutureConcept[T]
- Definition Classes
- ScalaFutures
- implicit val defaultPatience: PatienceConfig
- Definition Classes
- TestEssentials → ScalaFuturesWithPatience
- lazy val defaultStaticSynchronizerParameters: StaticSynchronizerParameters
- Attributes
- protected
- Definition Classes
- TestEssentials
- lazy val directExecutionContext: ExecutionContext
- Definition Classes
- TestEssentials
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, P19, P20, P21, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, P19, P20, P21) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassWrapper[P16], arg17: ValueClassWrapper[P17], arg18: ValueClassWrapper[P18], arg19: ValueClassWrapper[P19], arg20: ValueClassWrapper[P20], arg21: ValueClassWrapper[P21], arg22: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, P19, P20, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, P19, P20) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassWrapper[P16], arg17: ValueClassWrapper[P17], arg18: ValueClassWrapper[P18], arg19: ValueClassWrapper[P19], arg20: ValueClassWrapper[P20], arg21: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, P19, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, P19) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassWrapper[P16], arg17: ValueClassWrapper[P17], arg18: ValueClassWrapper[P18], arg19: ValueClassWrapper[P19], arg20: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, P18) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassWrapper[P16], arg17: ValueClassWrapper[P17], arg18: ValueClassWrapper[P18], arg19: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, P17) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassWrapper[P16], arg17: ValueClassWrapper[P17], arg18: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, P16) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassWrapper[P16], arg17: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, P15) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassWrapper[P15], arg16: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, P14) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassWrapper[P14], arg15: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, P13) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassWrapper[P13], arg14: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, P12) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassWrapper[P12], arg13: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, P11) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassWrapper[P11], arg12: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, P10) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassWrapper[P10], arg11: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, P9, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8, P9) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassWrapper[P9], arg10: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, P8, R](f: (P0, P1, P2, P3, P4, P5, P6, P7, P8) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassWrapper[P8], arg9: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, P7, R](f: (P0, P1, P2, P3, P4, P5, P6, P7) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassWrapper[P7], arg8: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, P6, R](f: (P0, P1, P2, P3, P4, P5, P6) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassWrapper[P6], arg7: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, P5, R](f: (P0, P1, P2, P3, P4, P5) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassWrapper[P5], arg6: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, P4, R](f: (P0, P1, P2, P3, P4) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassWrapper[P4], arg5: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, P3, R](f: (P0, P1, P2, P3) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassWrapper[P3], arg4: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, P2, R](f: (P0, P1, P2) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassWrapper[P2], arg3: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, P1, R](f: (P0, P1) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassWrapper[P1], arg2: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[P0, R](f: (P0) => R)(implicit arg0: ValueClassWrapper[P0], arg1: ValueClassExtractor[R], classTag: ClassTag[P0]): Stubber
- Definition Classes
- DoSomething
- def doAnswer[R](l: => R)(implicit arg0: ValueClassExtractor[R]): Stubber
- Definition Classes
- DoSomething
- def doCallRealMethod: Stubber
- Definition Classes
- DoSomething
- def doNothing: Stubber
- Definition Classes
- DoSomething
- def doReturn[T](toBeReturned: T, toBeReturnedNext: T*)(implicit arg0: ValueClassExtractor[T]): Stubber
- Definition Classes
- DoSomething
- def doThrow[T <: Throwable](implicit arg0: ClassTag[T]): Stubber
- Definition Classes
- DoSomething
- def doThrow(toBeThrown: Throwable*): Stubber
- Definition Classes
- DoSomething
- def doubleThat(matcher: ArgumentMatcher[Double]): Double
- Definition Classes
- ThatMatchers
- def endsWith(suffix: String): String
- Definition Classes
- StringThatMatchers
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def eqTo[T](value: T)(implicit arg0: Equality[T], arg1: ValueClassExtractor[T], arg2: Prettifier): T
- Definition Classes
- EqMatchers_VersionSpecific
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- def executionContextName: String
- Attributes
- protected
- Definition Classes
- HasExecutorServiceGeneric
- def executorService: ExecutionContextIdlenessExecutorService
- Attributes
- protected
- Definition Classes
- HasExecutorServiceGeneric
- def exitOnFatal: Boolean
- Attributes
- protected
- Definition Classes
- HasExecutorServiceGeneric
- def floatThat(matcher: ArgumentMatcher[Float]): Float
- Definition Classes
- ThatMatchers
- def function0[T](value: T): () => T
- Definition Classes
- FunctionMatchers
- val futureSupervisor: FutureSupervisor
- Definition Classes
- TestEssentials
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def handleFailure(message: String): Nothing
- Definition Classes
- SequencerBenchmark → HasExecutorServiceGeneric
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def ignoreStubs(mocks: AnyRef*): Array[AnyRef]
- Definition Classes
- MockitoEnhancer
- def inOrder(mocks: AnyRef*): InOrder
- Definition Classes
- Rest
- def intThat(matcher: ArgumentMatcher[Int]): Int
- Definition Classes
- ThatMatchers
- def interval(value: Span): Interval
- Definition Classes
- PatienceConfiguration
- implicit val invocationOps: (InvocationOnMock) => InvocationOnMockOps
- Definition Classes
- MockitoEnhancer
- def isA[T](implicit arg0: ClassTag[T]): T
- Definition Classes
- EqMatchers
- def isClosing: Boolean
Check whether we're closing.
Check whether we're closing. Susceptible to race conditions; unless you're using this as a flag to the retry lib or you really know what you're doing, prefer
performUnlessClosing
and friends.- Definition Classes
- OnShutdownRunner → HasUnlessClosing
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def keepTrackOfReaderCallStack: Boolean
Set this to true to get detailed information about all futures that did not complete during shutdown.
Set this to true to get detailed information about all futures that did not complete during shutdown.
- Attributes
- protected[this]
- Definition Classes
- PerformUnlessClosing → HasSynchronizeWithReaders
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: SuppressingLogger
- Definition Classes
- TestEssentials → NamedLogging
- def longThat(matcher: ArgumentMatcher[Long]): Long
- Definition Classes
- ThatMatchers
- def matches(regex: String): String
- Definition Classes
- StringThatMatchers
- def maxSleepMillis: Long
How often to poll to check that all tasks have completed.
How often to poll to check that all tasks have completed.
- Attributes
- protected
- Definition Classes
- PerformUnlessClosing
- var messageSize: Int
- def mkPromise[A](description: String, futureSupervisor: FutureSupervisor, logAfter: Duration = 10.seconds, logLevel: Level = Level.DEBUG)(implicit elc: ErrorLoggingContext): PromiseUnlessShutdown[A]
Use this method to create a PromiseUnlessShutdown that will automatically be cancelled when the close context is closed.
Use this method to create a PromiseUnlessShutdown that will automatically be cancelled when the close context is closed. This allows proper clean up of stray promises when the node is transitioning to a passive state.
Note: you should *not* invoke
success
on the returned promise but rather usetrySuccess
. The reason is that the call tosuccess
may fail in case of shutdown.- Definition Classes
- PromiseUnlessShutdownFactory
- def mock[T <: AnyRef](name: String)(implicit arg0: ClassTag[T], arg1: scala.reflect.api.JavaUniverse.WeakTypeTag[T], defaultAnswer: DefaultAnswer, arg3: Prettifier): T
- Definition Classes
- MockitoEnhancer → MockCreator
- def mock[T <: AnyRef](mockSettings: MockSettings)(implicit arg0: ClassTag[T], arg1: scala.reflect.api.JavaUniverse.WeakTypeTag[T], arg2: Prettifier): T
- Definition Classes
- MockitoEnhancer → MockCreator
- def mock[T <: AnyRef](defaultAnswer: DefaultAnswer)(implicit arg0: ClassTag[T], arg1: scala.reflect.api.JavaUniverse.WeakTypeTag[T], arg2: Prettifier): T
- Definition Classes
- MockitoEnhancer → MockCreator
- def mock[T <: AnyRef](implicit arg0: ClassTag[T], arg1: scala.reflect.api.JavaUniverse.WeakTypeTag[T], defaultAnswer: DefaultAnswer, arg3: Prettifier): T
- Definition Classes
- MockitoEnhancer → MockCreator
- def mock[T <: AnyRef](defaultAnswer: Answer[_])(implicit arg0: ClassTag[T], arg1: scala.reflect.api.JavaUniverse.WeakTypeTag[T], arg2: Prettifier): T
- Definition Classes
- MockCreator
- def mockingDetails(toInspect: AnyRef): MockingDetails
- Definition Classes
- MockitoEnhancer
- implicit def mockitoSerialisableEquality[T]: Equality[T]
- Definition Classes
- ScalacticSerialisableHack
- val n: N
- Definition Classes
- NumericMatchers
- def nameInternal: String
- Attributes
- protected[this]
- Definition Classes
- PerformUnlessClosing → HasSynchronizeWithReaders
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def never: VerificationMode
- Definition Classes
- Verifications
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- lazy val nonEmptyTraceContext1: TraceContext
- Attributes
- protected
- Definition Classes
- TestEssentials
- lazy val nonEmptyTraceContext2: TraceContext
- Attributes
- protected
- Definition Classes
- TestEssentials
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def onCloseFailure(e: Throwable): Unit
- Attributes
- protected
- Definition Classes
- PerformUnlessClosing
- def onClosed(): Unit
- Attributes
- protected
- Definition Classes
- PerformUnlessClosing
- final def onFirstClose(): Unit
Blocks until all earlier tasks have completed and then prevents further tasks from being run.
Blocks until all earlier tasks have completed and then prevents further tasks from being run.
- Definition Classes
- PerformUnlessClosing → OnShutdownRunner
- Annotations
- @SuppressWarnings()
- def only: VerificationMode
- Definition Classes
- Verifications
- implicit def parallelExecutionContext: ExecutionContextIdlenessExecutorService
- implicit def patienceConfig: PatienceConfig
- Definition Classes
- PatienceConfiguration → AbstractPatienceConfiguration
- def performUnlessClosing[A](name: String)(f: => A)(implicit traceContext: TraceContext): UnlessShutdown[A]
Performs the task given by
f
unless a shutdown has been initiated.Performs the task given by
f
unless a shutdown has been initiated. The shutdown will only begin afterf
completes, but other tasks may execute concurrently withf
, if started using this function, or one of the other variants (performUnlessClosingF and performUnlessClosingEitherT). The tasks are assumed to take less than closingTimeout to complete.DO NOT CALL
this.close
as part off
, because it will result in a deadlock. DO NOT PUT retries, especially indefinite ones, insidef
.- f
The task to perform
- returns
scala.None$ if a shutdown has been initiated. Otherwise the result of the task.
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingCheckedT[A, N, R](name: String, onClosing: => Checked[A, N, R])(etf: => CheckedT[Future, A, N, R])(implicit ec: ExecutionContext, traceContext: TraceContext): CheckedT[Future, A, N, R]
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingCheckedUST[A, N, R](name: String, onClosing: => Checked[A, N, R])(etf: => CheckedT[FutureUnlessShutdown, A, N, R])(implicit ec: ExecutionContext, traceContext: TraceContext): CheckedT[FutureUnlessShutdown, A, N, R]
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingEitherT[E, R](name: String, onClosing: => E)(etf: => EitherT[Future, E, R])(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[Future, E, R]
Performs the EitherT[Future] given by
etf
unless a shutdown has been initiated, in which case the provided error is returned instead.Performs the EitherT[Future] given by
etf
unless a shutdown has been initiated, in which case the provided error is returned instead. Bothetf
and the error are lazy;etf
is only evaluated if there is no shutdown, the error only if we're shutting down. The shutdown will only begin afteretf
completes, but other tasks may execute concurrently withetf
, if started using this function, or one of the other variants (performUnlessClosing and performUnlessClosingF). The tasks are assumed to take less than closingTimeout to complete.DO NOT CALL
this.close
as part ofetf
, because it will result in a deadlock. DO NOT PUT retries, especially indefinite ones, insidef
.- etf
The task to perform
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingEitherU[E, R](name: String)(etf: => EitherT[Future, E, R])(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[FutureUnlessShutdown, E, R]
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingEitherUSF[E, R](name: String)(etf: => EitherT[FutureUnlessShutdown, E, R])(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[FutureUnlessShutdown, E, R]
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingEitherUSFAsync[E, R](name: String)(etf: => EitherT[FutureUnlessShutdown, E, R])(asyncResultToWaitForF: (R) => FutureUnlessShutdown[_])(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[FutureUnlessShutdown, E, R]
Use this method if closing/shutdown of the object should wait for asynchronous computation to finish too.
Use this method if closing/shutdown of the object should wait for asynchronous computation to finish too.
- etf
closing of this object will wait for all such spawned Futures to finish
- asyncResultToWaitForF
closing of this object will wait also wait for all such asynchronous Futures to finish too
- returns
the future spawned by etf
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingF[A](name: String)(f: => Future[A])(implicit ec: ExecutionContext, traceContext: TraceContext): FutureUnlessShutdown[A]
Performs the Future given by
f
unless a shutdown has been initiated.Performs the Future given by
f
unless a shutdown has been initiated. The future is lazy and not evaluated during shutdown. The shutdown will only begin afterf
completes, but other tasks may execute concurrently withf
, if started using this function, or one of the other variants (performUnlessClosing and performUnlessClosingEitherT). The tasks are assumed to take less than closingTimeout to complete.DO NOT CALL
this.close
as part off
, because it will result in a deadlock. DO NOT PUT retries, especially indefinite ones, insidef
.- f
The task to perform
- returns
The future completes with com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown if a shutdown has been initiated. Otherwise the result of the task wrapped in com.digitalasset.canton.lifecycle.UnlessShutdown.Outcome.
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingOptionUSF[R](name: String)(otf: => OptionT[FutureUnlessShutdown, R])(implicit ec: ExecutionContext, traceContext: TraceContext): OptionT[FutureUnlessShutdown, R]
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingUSF[A](name: String)(f: => FutureUnlessShutdown[A])(implicit ec: ExecutionContext, traceContext: TraceContext): FutureUnlessShutdown[A]
- Definition Classes
- PerformUnlessClosing
- def performUnlessClosingUSFAsync[A](name: String)(f: => FutureUnlessShutdown[A])(asyncResultToWaitForF: (A) => FutureUnlessShutdown[_])(implicit ec: ExecutionContext, traceContext: TraceContext): FutureUnlessShutdown[A]
Use this method if closing/shutdown of the object should wait for asynchronous computation to finish too.
Use this method if closing/shutdown of the object should wait for asynchronous computation to finish too.
- f
closing of this object will wait for all such spawned Futures to finish
- asyncResultToWaitForF
closing of this object will wait also wait for all such asynchronous Futures to finish too
- returns
the future spawned by f
- Definition Classes
- PerformUnlessClosing
- def refEq[T](value: T, excludeFields: String*): T
- Definition Classes
- EqMatchers
- def remainingReaders(): Seq[String]
- Attributes
- protected[this]
- Definition Classes
- HasSynchronizeWithReaders
- def removeReader(handle: ReaderHandle): Unit
TODO(#16601) Make this method private once PerformUnlessClosing doesn't need it any more
TODO(#16601) Make this method private once PerformUnlessClosing doesn't need it any more
- Attributes
- protected[this]
- Definition Classes
- HasSynchronizeWithReaders
- def reset(mocks: AnyRef*)(implicit arg0: Prettifier): Unit
- Definition Classes
- MockitoEnhancer
- def runOnClose(task: RunOnClosing): UnlessShutdown[LifeCycleRegistrationHandle]
Schedules the given task to be run upon closing.
Schedules the given task to be run upon closing.
- returns
An com.digitalasset.canton.lifecycle.UnlessShutdown.Outcome indicates that the task will have been run when the
LifeCycleManager
'scloseAsync
method completes or whenAutoCloseable
'sclose
method returns, unless the returnedLifeCycleRegistrationHandle
was used to cancel the task or the task has been done beforehand. com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown if the task is not run due to closing. This always happens if isClosing returns true.
- Definition Classes
- OnShutdownRunner → HasRunOnClosing
- def runOnOrAfterClose(task: RunOnClosing)(implicit traceContext: TraceContext): LifeCycleRegistrationHandle
Register a task to run when closing is initiated, or run it immediately if closing is already ongoing.
Register a task to run when closing is initiated, or run it immediately if closing is already ongoing. Unlike runOnClose, this method does not guarantee that this task will have run by the time the
LifeCycleManager
'scloseAsync
method completes orAutoCloseable
'sclose
returns. This is because the task is run immediately if the component has already been closed.- Definition Classes
- HasRunOnClosing
- final def runOnOrAfterClose_(task: RunOnClosing)(implicit traceContext: TraceContext): Unit
Variant of runOnOrAfterClose that does not return a com.digitalasset.canton.lifecycle.LifeCycleRegistrationHandle.
Variant of runOnOrAfterClose that does not return a com.digitalasset.canton.lifecycle.LifeCycleRegistrationHandle.
- Definition Classes
- HasRunOnClosing
- def runTaskUnlessDone(task: RunOnClosing)(implicit traceContext: TraceContext): Unit
- Attributes
- protected[this]
- Definition Classes
- OnShutdownRunner → HasRunOnClosing
- def same[T](value: T): T
- Definition Classes
- EqMatchers
- final def scaled(span: Span): Span
- Definition Classes
- ScaledTimeSpans
- def scheduledExecutor(): ScheduledExecutorService
- Attributes
- protected
- Definition Classes
- HasExecutorServiceGeneric
- def scheduler: ScheduledExecutorService
- def sendDirect(ctrl: Control): Unit
- Annotations
- @Benchmark() @BenchmarkMode() @Threads()
- def setupBenchmarkRun(): Unit
- Annotations
- @Setup()
- def shortThat(matcher: ArgumentMatcher[Short]): Short
- Definition Classes
- ThatMatchers
- def spanScaleFactor: Double
- Definition Classes
- ScaledTimeSpans
- def spy[T <: AnyRef](realObj: T, lenient: Boolean)(implicit arg0: ClassTag[T], arg1: scala.reflect.api.JavaUniverse.WeakTypeTag[T], arg2: Prettifier): T
- Definition Classes
- MockitoEnhancer → MockCreator
- def spyLambda[T <: AnyRef](realObj: T)(implicit arg0: ClassTag[T]): T
- Definition Classes
- MockitoEnhancer → MockCreator
- def startsWith(prefix: String): String
- Definition Classes
- StringThatMatchers
- def synchronizeWithClosingPatience: FiniteDuration
- Attributes
- protected[this]
- Definition Classes
- PerformUnlessClosing → HasSynchronizeWithReaders
- def synchronizeWithReaders()(implicit traceContext: TraceContext): Boolean
- Attributes
- protected[this]
- Definition Classes
- HasSynchronizeWithReaders
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def tearDown(): Unit
- Annotations
- @TearDown()
- lazy val testedProtocolVersion: ProtocolVersion
- Attributes
- protected
- Definition Classes
- TestEssentials
- lazy val testedProtocolVersionValidation: ProtocolVersionValidation
- Attributes
- protected
- Definition Classes
- TestEssentials
- lazy val testedReleaseProtocolVersion: ReleaseProtocolVersion
- Attributes
- protected
- Definition Classes
- TestEssentials
- def timeout(millis: Int): VerificationWithTimeout
- Definition Classes
- Verifications
- def timeout(value: Span): Timeout
- Definition Classes
- PatienceConfiguration
- def timeouts: ProcessingTimeout
- Attributes
- protected
- Definition Classes
- TestEssentials
- def times(wantedNumberOfInvocations: Int): VerificationMode
- Definition Classes
- Verifications
- def toString(): String
- Definition Classes
- AnyRef → Any
- implicit def traceContext: TraceContext
- Attributes
- protected
- Definition Classes
- TestEssentials
- implicit lazy val tracer: Tracer
- Attributes
- protected
- Definition Classes
- TestEssentials
- final def unlessClosing[F[_], A](fa: => F[A])(implicit F: CanAbortDueToShutdown[F]): F[A]
Runs the computation
fa
unless isClosing returns true.Runs the computation
fa
unless isClosing returns true.This method does not delay the closing while
fa
is running, unlike the methods inHasSynchronizeWithClosing
. Accordingly, this method is useful for intermittent checks whether the result of the computation is still relevant.- returns
The result of
fa
or com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown if isClosing is true
- Definition Classes
- HasUnlessClosing
- Annotations
- @inline()
- def validateMockitoUsage(): Unit
- Definition Classes
- Rest
- def valueOrThrow[F[_], A, B](e: EitherT[F, A, B])(clue: String)(implicit F: Functor[F]): F[B]
Converts an EitherT into a Future, throwing the exception in case of a scala.Left$.
- def verify[T](mock: T, mode: VerificationMode): T
- Definition Classes
- Rest
- def verify[T](mock: T): T
- Definition Classes
- Rest
- def verifyNoMoreInteractions(mocks: AnyRef*): Unit
- Definition Classes
- MockitoEnhancer
- def verifyZeroInteractions(mocks: AnyRef*): Unit
- Definition Classes
- Rest
- 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])
- lazy val wallClock: WallClock
- Definition Classes
- TestEssentials
- def when[T](methodCall: T)(implicit arg0: ValueClassExtractor[T]): ScalaFirstStubbing[T]
- Definition Classes
- Rest
- final def whenReady[T, U](future: FutureConcept[T])(fun: (T) => U)(implicit config: PatienceConfig, pos: Position): U
- Definition Classes
- Futures
- final def whenReady[T, U](future: FutureConcept[T], interval: Interval)(fun: (T) => U)(implicit config: PatienceConfig, pos: Position): U
- Definition Classes
- Futures
- final def whenReady[T, U](future: FutureConcept[T], timeout: Timeout)(fun: (T) => U)(implicit config: PatienceConfig, pos: Position): U
- Definition Classes
- Futures
- final def whenReady[T, U](future: FutureConcept[T], timeout: Timeout, interval: Interval)(fun: (T) => U)(implicit config: PatienceConfig, pos: Position): U
- Definition Classes
- Futures
- def withObjectMocked[O <: AnyRef](block: => Any)(implicit arg0: ClassTag[O], defaultAnswer: DefaultAnswer, arg2: Prettifier): Unit
- Definition Classes
- MockitoEnhancer
- def withReader[F[_], A](name: String)(f: => F[A])(implicit traceContext: TraceContext, F: Thereafter[F]): UnlessShutdown[F[A]]
- Attributes
- protected[this]
- Definition Classes
- HasSynchronizeWithReaders
- def withSettings(implicit defaultAnswer: DefaultAnswer): MockSettings
- Definition Classes
- MockCreator
Deprecated Value Members
- def anyVal[T](implicit default: DefaultValueProvider[T]): T
- Definition Classes
- MacroBasedMatchers
- Annotations
- @deprecated
- Deprecated
(Since version 1.0.2) Use 'any[T]' or '*[T]' instead
- def eqToVal[T](value: T)(implicit arg0: Equality[T], arg1: ValueClassExtractor[T], arg2: Prettifier): T
- Definition Classes
- EqMatchers_VersionSpecific
- Annotations
- @deprecated
- Deprecated
(Since version 1.0.2) Use 'eqTo' instead
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def isNotNull[T]: T
- Definition Classes
- NullMatchers
- Annotations
- @deprecated
- Deprecated
(Since version 0.0.0) Using nulls in Scala? you naughty, naughty developer...
- def isNull[T]: T
- Definition Classes
- NullMatchers
- Annotations
- @deprecated
- Deprecated
(Since version 0.0.0) Using nulls in Scala? you naughty, naughty developer...