object CommitDelivery
Selects how the stream delivers commits to the internal actor.
- Annotations
- @ApiMayChange()
- Source
- CommitterSettings.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CommitDelivery
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
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 equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- 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()
- val sendAndForget: CommitDelivery
Java API.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def valueOf(s: String): CommitDelivery
- 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()
- val waitForAck: CommitDelivery
Java API.
- case object SendAndForget extends CommitDelivery with Product with Serializable
Send off commits to the internal actor without expecting replies, and don't create backpressure in the stream.
Send off commits to the internal actor without expecting replies, and don't create backpressure in the stream.
- Annotations
- @ApiMayChange()
- case object WaitForAck extends CommitDelivery with Product with Serializable
Expect replies for commits, and backpressure the stream if replies do not arrive.
Expect replies for commits, and backpressure the stream if replies do not arrive.
- Annotations
- @ApiMayChange()