case class Complete[R <: Response](ready: ReadyForQuery, response: Option[Try[R]]) extends TransitionResult[Nothing, R] with Product with Serializable
Indicates that the state machine is finished and the connection may be released.
Postgres uses the ReadyForQuery message to indicate this to the client, so it is expected to be provided here.
Also, if completing the sate machine should also complete the client's response, then the value to produce
can be provided in the response
field. If the client's promise has already been fulfilled, this will have
no effect.
- ready
the ReadyForQuery message from the backend confirming the connection's state.
- response
an optional value to used to fulfill the client's promise. If this is None, then the Respond action must have been produced during the state machine's lifecycle to guarantee the client receives a response.
- Alphabetic
- By Inheritance
- Complete
- Serializable
- Product
- Equals
- TransitionResult
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Complete(ready: ReadyForQuery, response: Option[Try[R]])
- ready
the ReadyForQuery message from the backend confirming the connection's state.
- response
an optional value to used to fulfill the client's promise. If this is None, then the Respond action must have been produced during the state machine's lifecycle to guarantee the client receives a response.
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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val ready: ReadyForQuery
- val response: Option[Try[R]]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()