Packages

object R2dbcSession

Source
R2dbcSession.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. R2dbcSession
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def withSession[A](system: ActorSystem[_], connectionFactory: ConnectionFactory, fun: Function[R2dbcSession, CompletionStage[A]]): CompletionStage[A]

    Provide a custom connectionFactory.

    Provide a custom connectionFactory. The config closeCallsExceeding is loaded from the default path.

  2. def withSession[A](system: ActorSystem[_], connectionFactoryConfigPath: String, fun: Function[R2dbcSession, CompletionStage[A]]): CompletionStage[A]
  3. def withSession[A](system: ActorSystem[_], fun: Function[R2dbcSession, CompletionStage[A]]): CompletionStage[A]

    Runs the passed function in using a R2dbcSession with a new transaction.

    Runs the passed function in using a R2dbcSession with a new transaction. The connection is closed and the transaction is committed at the end or rolled back in case of failures.