abstract class AsyncTest[TDB >: Null <: TestDB] extends GenericTest[TDB]
- Alphabetic
- By Inheritance
- AsyncTest
- GenericTest
- AnyRef
- Any
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new AsyncTest()(implicit TdbClass: ClassTag[TDB])
Type Members
- implicit class AssertionExtensionMethods[T] extends AnyRef
- implicit class CollectionAssertionExtensionMethods[T] extends AnyRef
- implicit class CollectionDBIOActionExtensionMethods[T, +S <: NoStream, -E <: Effect] extends AnyRef
- implicit class DBIOActionExtensionMethods[T, +S <: NoStream, -E <: Effect] extends AnyRef
- implicit class StringExtensionMethods extends AnyRef
- Definition Classes
- GenericTest
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def ->[B](y: B): (AsyncTest[TDB], B)
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- var _tdb: TDB
- Attributes
- protected[this]
- Definition Classes
- GenericTest
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def assertNesting(q: Rep[_], exp: Int): Unit
- Definition Classes
- GenericTest
- implicit def asyncTestExecutionContext: ExecutionContextExecutor
- Attributes
- protected
- final def cleanup(): Unit
- Definition Classes
- GenericTest
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def closeKeepAlive(): Unit
- Definition Classes
- GenericTest
- lazy val db: slick.basic.BasicProfile.Backend.Database
- Definition Classes
- GenericTest
- def ensuring(cond: (AsyncTest[TDB]) => Boolean, msg: => Any): AsyncTest[TDB]
- def ensuring(cond: (AsyncTest[TDB]) => Boolean): AsyncTest[TDB]
- def ensuring(cond: Boolean, msg: => Any): AsyncTest[TDB]
- def ensuring(cond: Boolean): AsyncTest[TDB]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def foreach[T](p: Publisher[T])(f: (T) => Any): Future[Unit]
Iterate synchronously over a Reactive Stream.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def ifCap[E <: Effect, R](caps: Capability*)(f: => DBIOAction[R, NoStream, E]): DBIOAction[Unit, NoStream, E]
- def ifCapF[R](caps: Capability*)(f: => Future[R]): Future[Unit]
- def ifCapU[T](caps: Capability*)(f: => T): Unit
- def ifNotCap[E <: Effect, R](caps: Capability*)(f: => DBIOAction[R, NoStream, E]): DBIOAction[Unit, NoStream, E]
- def ifNotCapF[R](caps: Capability*)(f: => Future[R]): Future[Unit]
- def ifNotCapU[T](caps: Capability*)(f: => T): Unit
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def jcap: JdbcCapabilities
- Definition Classes
- GenericTest
- final def mark[R, S <: NoStream, E <: Effect](id: String, f: => DBIOAction[R, S, E]): DBIOAction[R, S, E]
- Definition Classes
- GenericTest
- final def mark[T](id: String, f: => T): T
- Definition Classes
- GenericTest
- def materialize[T](p: Publisher[T]): Future[Vector[T]]
Synchronously consume a Reactive Stream and materialize it as a Vector.
- def materializeAsync[T, R](p: Publisher[T], tr: (T) => Future[R], delay: Duration = Duration(100L, TimeUnit.MILLISECONDS)): Future[Vector[R]]
Asynchronously consume a Reactive Stream and materialize it as a Vector, requesting new elements one by one and transforming them after the specified delay.
Asynchronously consume a Reactive Stream and materialize it as a Vector, requesting new elements one by one and transforming them after the specified delay. This ensures that the transformation does not run in the synchronous database context but still preserves proper sequencing.
- 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 rcap: RelationalCapabilities
- Definition Classes
- GenericTest
- final val reuseInstance: Boolean
- Definition Classes
- AsyncTest → GenericTest
- def scap: SqlCapabilities
- Definition Classes
- GenericTest
- def seq[E <: Effect](actions: DBIOAction[_, NoStream, E]*): DBIOAction[Unit, NoStream, E]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def tcap: capabilities
- Definition Classes
- GenericTest
- lazy val tdb: TDB
- Definition Classes
- GenericTest
- 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])
- object GetSession extends SynchronousDatabaseAction[slick.basic.BasicProfile.Backend.Session, NoStream, TestDB.Profile.Backend, Effect]
Test Action: Get the current database session
- object GetStatementParameters extends SynchronousDatabaseAction[StatementParameters, NoStream, JdbcBackend, Effect]
Test Action: Get the current statement parameters, except for
statementInit
which is always set to null - object GetTransactionality extends SynchronousDatabaseAction[(Int, Boolean), NoStream, JdbcBackend, Effect]
Test Action: Get the current transactionality level and autoCommit flag
- object IsPinned extends SynchronousDatabaseAction[Boolean, NoStream, TestDB.Profile.Backend, Effect]
Test Action: Check if the current database session is pinned
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from AsyncTest[TDB] toStringFormat[AsyncTest[TDB]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)
instead ofvalue.formatted(formatString)
, or use thef""
string interpolator. In Java 15 and later,formatted
resolves to the new method in String which has reversed parameters.
- def →[B](y: B): (AsyncTest[TDB], B)
- Implicit
- This member is added by an implicit conversion from AsyncTest[TDB] toArrowAssoc[AsyncTest[TDB]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->
instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.