Packages

trait Operator[R, E, T] extends AnyRef

Core implementation of the operator logic. Watches a stream and calls an event processor.

An instance of this is tied to one particular resource type in one namespace.

Create an instance using either Operator.namespaced() or Operator.cluster()

Self Type
Operator[R, E, T]
Linear Supertypes
AnyRef, Any
Known Subclasses
ClusterOperator, NamespacedOperator
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Operator
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract val bufferSize: Int
  2. abstract val context: OperatorContext
  3. abstract def mapEventProcessor[R1, E1](f: (ZIO[R, OperatorFailure[E], Unit]) ⇒ ZIO[R1, OperatorFailure[E1], Unit]): Operator[R1, E1, T]

    Modify the operator's event processor with the given function

  4. abstract def processEvent(event: TypedWatchEvent[T]): ZIO[R, OperatorFailure[E], Unit]

Concrete Value Members

  1. final def provideCustomLayer[E1 >: E, R1 <: ZEnvironment[_]](layer: ⇒ ZLayer[Any, OperatorFailure[E1], R1])(implicit ev: <:<[R1, R], tagged: zio.EnvironmentTag[R1]): Operator[Any, E1, T]

    Provide the required environment for the operator with a layer on top of the standard ones

  2. final def provideLayer[E1 >: E, R0, R1](layer: ⇒ ZLayer[R0, OperatorFailure[E1], R]): Operator[R0, E1, T]

    Provide the required environment for the operator with a layer

  3. final def provideSomeLayer[R0 <: ZEnvironment[_]]: ProvideSomeLayer[R0, R, E, T]

    Provide parts of the required environment for the operator with a layer

  4. def start(): URIO[R, Runtime[Nothing, Unit]]

    Starts the operator on a forked fiber

  5. def stream(): ZStream[R, OperatorFailure[E], Unit]

    Exposes stream

  6. implicit def toThrowable: ConvertableToThrowable[E]