object ResourceOwner extends ResourceOwnerFactories[ExecutionContext] with PekkoResourceOwnerFactories[ExecutionContext] with GrpcResourceOwnerFactories[ExecutionContext]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ResourceOwner
- GrpcResourceOwnerFactories
- PekkoResourceOwnerFactories
- ResourceOwnerFactories
- 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
- val EventLoopGroupChannelType: Class[_ <: Channel]
- Definition Classes
- GrpcResourceOwnerFactories
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def failed(throwable: Throwable): AbstractResourceOwner[ExecutionContext, Nothing]
- Definition Classes
- ResourceOwnerFactories
- def forActorSystem(acquire: () => ActorSystem): AbstractResourceOwner[ExecutionContext, ActorSystem]
- Definition Classes
- PekkoResourceOwnerFactories
- def forBoundedSourceQueue[T, U](queueGraph: RunnableGraph[(BoundedSourceQueue[T], Future[U])])(implicit materializer: Materializer): AbstractResourceOwner[ExecutionContext, (BoundedSourceQueue[T], Future[U])]
- Definition Classes
- PekkoResourceOwnerFactories
- def forCancellable[C <: Cancellable](acquire: () => C): AbstractResourceOwner[ExecutionContext, C]
- Definition Classes
- PekkoResourceOwnerFactories
- def forChannel(builder: ManagedChannelBuilder[_], shutdownTimeout: FiniteDuration): AbstractResourceOwner[ExecutionContext, Channel]
- Definition Classes
- GrpcResourceOwnerFactories
- def forCloseable[T <: AutoCloseable](acquire: () => T): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forCompletionStage[T](acquire: () => CompletionStage[T]): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forEventLoopGroup(threadCount: Int, threadFactory: ThreadFactory): AbstractResourceOwner[ExecutionContext, EventLoopGroup]
- Definition Classes
- GrpcResourceOwnerFactories
- def forExecutorService[T <: ExecutorService](acquire: () => T, gracefulAwaitTerminationMillis: Long, forcefulAwaitTerminationMillis: Long): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forFuture[T](acquire: () => Future[T]): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forFutureCloseable[T <: AutoCloseable](acquire: () => Future[T]): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forMaterializer(acquire: () => Materializer): AbstractResourceOwner[ExecutionContext, Materializer]
- Definition Classes
- PekkoResourceOwnerFactories
- def forMaterializerDirectly(acquire: () => ActorSystem): AbstractResourceOwner[ExecutionContext, Materializer]
- Definition Classes
- PekkoResourceOwnerFactories
- def forReleasable[T](acquire: () => T)(release: (T) => Future[Unit]): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forServer(builder: ServerBuilder[_], shutdownTimeout: FiniteDuration): AbstractResourceOwner[ExecutionContext, Server]
- Definition Classes
- GrpcResourceOwnerFactories
- def forTimer(acquire: () => Timer, waitForRunningTasks: Boolean): AbstractResourceOwner[ExecutionContext, Timer]
- Definition Classes
- ResourceOwnerFactories
- def forTry[T](acquire: () => Try[T]): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forTryCloseable[T <: AutoCloseable](acquire: () => Try[T]): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- def forValue[T](acquire: () => T): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- implicit val hasExecutionContext: HasExecutionContext[ExecutionContext]
- Attributes
- protected
- Definition Classes
- ResourceOwner → GrpcResourceOwnerFactories → PekkoResourceOwnerFactories → ResourceOwnerFactories
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def successful[T](value: T): AbstractResourceOwner[ExecutionContext, T]
- Definition Classes
- ResourceOwnerFactories
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def unit: AbstractResourceOwner[ExecutionContext, Unit]
- Definition Classes
- ResourceOwnerFactories
- 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()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])