trait StreamCancelledContext extends CrdtContext with EffectContext
Context for a stream cancelled event.
This is sent to callbacks registered by StreamedCommandContext#onCancel(Consumer).
- Alphabetic
- By Inheritance
- StreamCancelledContext
- EffectContext
- CrdtContext
- EntityContext
- Context
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
commandId(): Long
The id of the command that the stream was for.
The id of the command that the stream was for.
- returns
The ID of the command.
-
abstract
def
effect(effect: ServiceCall, synchronous: Boolean): Unit
Invoke the referenced service call as an effect once this action is completed.
Invoke the referenced service call as an effect once this action is completed.
ServiceCallinstances can be created using theServiceCallFactoryobtained from any (including this) contextsContext#serviceCallFactory()method.- effect
The service call to make as an effect effect.
- synchronous
Whether the effect should be performed synchronously (ie, wait till it has finished before sending a reply) or asynchronously.
- Definition Classes
- EffectContext
-
abstract
def
entityId(): String
The id of the entity that this context is for.
The id of the entity that this context is for.
- returns
The entity id.
- Definition Classes
- EntityContext
-
abstract
def
serviceCallFactory(): ServiceCallFactory
Get the service call factory for this stateful service.
Get the service call factory for this stateful service.
- Definition Classes
- Context
-
abstract
def
state[T <: Crdt](crdtClass: Class[T]): Optional[T]
The current CRDT, if it's been created.
The current CRDT, if it's been created.
- crdtClass
The type of the CRDT that is expected.
- returns
The current CRDT, or empty if none has been created yet.
- Definition Classes
- CrdtContext
- Exceptions thrown
IllegalStateExceptionIf the current CRDT does not match the passed incrdtClasstype.
Concrete 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( ... ) @native()
-
def
effect(effect: ServiceCall): Unit
Invoke the referenced service call as an effect once this action is completed.
Invoke the referenced service call as an effect once this action is completed.
The effect will be performed asynchronously, ie, the proxy won't wait for the effect to finish before sending the reply.
ServiceCallinstances can be created using theServiceCallFactoryobtained from any (including this) contextsContext#serviceCallFactory()method.- effect
The service call to make as an effect effect.
- Definition Classes
- EffectContext
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- 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()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()