Packages

object ZTestActivityEnvironment

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

Type Members

  1. final class ActivityRunOptionsWithZIOPartiallyApplied[R] extends AnyVal

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def activityRunOptions[R](implicit arg0: Tag[R]): URIO[ZTestActivityEnvironment[R], ZActivityRunOptions[R]]
  5. def activityRunOptionsWithZIO[R]: ActivityRunOptionsWithZIOPartiallyApplied[R]

    Access activity options

  6. def addActivityImplementation[A <: AnyRef](activity: A)(implicit arg0: ExtendsActivity[A]): URIO[ZTestActivityEnvironment[Any], Unit]

    Registers activity implementations to test.

    Registers activity implementations to test. Use newActivityStub to create stubs that can be used to invoke them.

    Implementations that share a worker must implement different interfaces as an activity type is identified by the activity interface, not by the implementation.

    Exceptions thrown

    TypeAlreadyRegisteredException if one of the activity types is already registered

  7. def addActivityImplementationService[A <: AnyRef](implicit arg0: ExtendsActivity[A], arg1: Tag[A]): URIO[ZTestActivityEnvironment[Any] with A, Unit]

    Registers activity implementations to test.

    Registers activity implementations to test. Use newActivityStub to create stubs that can be used to invoke them.

    Implementations that share a worker must implement different interfaces as an activity type is identified by the activity interface, not by the implementation.

    Exceptions thrown

    TypeAlreadyRegisteredException if one of the activity types is already registered

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. def make[R](implicit arg0: Tag[R]): URLayer[R with ZTestEnvironmentOptions, ZTestActivityEnvironment[R]]

    Creates a new instance of ZTestActivityEnvironment

    Creates a new instance of ZTestActivityEnvironment

    returns

    managed instance of test activity environment

    See also

    TestActivityEnvironment.newInstance

  16. def makeDefault[R](implicit arg0: Tag[R]): URLayer[R, ZTestActivityEnvironment[Any]]

    Creates a new instance of ZTestActivityEnvironment with default options

    Creates a new instance of ZTestActivityEnvironment with default options

    returns

    managed instance of test activity environment

  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. def newActivityStub[A <: AnyRef](options: ZActivityOptions)(implicit arg0: IsActivity[A], arg1: ClassTag[A]): URIO[ZTestActivityEnvironment[Any], A]

    Creates a stub that can be used to invoke activities registered through addActivityImplementation

    Creates a stub that can be used to invoke activities registered through addActivityImplementation

    A

    Type of the activity interface.

    options

    activity options

    returns

    The stub builder for the activity.

    Note

    it's not a zio.temporal.activity.ZActivityStub because the activity is invoked locally. Wrapping method invocation into zio.temporal.activity.ZActivityStub.execute is not required

  19. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  20. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  21. def requestCancelActivity(): URIO[ZTestActivityEnvironment[Any], Unit]

    Requests activity cancellation.

    Requests activity cancellation. The cancellation is going to be delivered to the activity on the next heartbeat.

  22. def setActivityHeartbeatListener[T](listener: (T) => Unit)(implicit arg0: JavaTypeTag[T]): URIO[ZTestActivityEnvironment[Any], Unit]

    Sets a listener that is called every time an activity implementation heartbeats through zio.temporal.activity.ZActivityExecutionContext.heartbeat

    Sets a listener that is called every time an activity implementation heartbeats through zio.temporal.activity.ZActivityExecutionContext.heartbeat

    T

    type of the details passed to the zio.temporal.activity.ZActivityExecutionContext.heartbeat

    listener

    listener to register.

  23. def setHeartbeatDetails[T](details: T): URIO[ZTestActivityEnvironment[Any], Unit]

    Sets heartbeat details for the next activity execution.

    Sets heartbeat details for the next activity execution. The next activity called from this TestActivityEnvironment will be able to access this value using zio.temporal.activity.ZActivityExecutionContext.heartbeat. This value is cleared upon execution.

    T

    Type of the heartbeat details.

    details

    The details object to make available to the next activity call.

  24. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. def newActivityStub[A <: AnyRef](implicit arg0: IsActivity[A], arg1: ClassTag[A]): ZActivityStubBuilderInitial[URIO[ZTestActivityEnvironment[Any], A]]

    Creates a stub that can be used to invoke activities registered through addActivityImplementation

    Creates a stub that can be used to invoke activities registered through addActivityImplementation

    A

    Type of the activity interface.

    returns

    The stub builder for the activity.

    Annotations
    @deprecated
    Deprecated

    (Since version 0.6.0) Use newLocalActivityStub accepting ZLocalActivityOptions

    Note

    it's not a zio.temporal.activity.ZActivityStub because the activity is invoked locally. Wrapping method invocation into zio.temporal.activity.ZActivityStub.execute is not required

Inherited from AnyRef

Inherited from Any

Ungrouped