Package io.servicetalk.concurrent.api

Class ExecutorExtension<E extends Executor>

java.lang.Object

io.servicetalk.concurrent.api.ExecutorExtension<E>

Type Parameters:

E - The type of Executor.

All Implemented Interfaces:

org.junit.jupiter.api.extension.AfterEachCallback, org.junit.jupiter.api.extension.BeforeEachCallback, org.junit.jupiter.api.extension.Extension

public final class ExecutorExtension<E extends Executor>
extends java.lang.Object
implements org.junit.jupiter.api.extension.BeforeEachCallback, org.junit.jupiter.api.extension.AfterEachCallback

An Extension wrapper for an Executor.

Method Summary

Modifier and Type	Method	Description
void	afterEach(org.junit.jupiter.api.extension.ExtensionContext context)
void	beforeEach(org.junit.jupiter.api.extension.ExtensionContext context)
E	executor()	Returns Executor created on the last call to beforeEach(ExtensionContext) ()}.
static ExecutorExtension<Executor>	withCachedExecutor()	Create an ExecutorExtension with a default executor.
static ExecutorExtension<Executor>	withCachedExecutor(java.lang.String namePrefix)	Create an ExecutorExtension with a default executor, configured to prefix thread names with namePrefix.
static ExecutorExtension<Executor>	withExecutor(java.util.function.Supplier<Executor> executorSupplier)	Create an ExecutorExtension with the specified executor.
static ExecutorExtension<TestExecutor>	withTestExecutor()	Create an ExecutorExtension with a TestExecutor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withCachedExecutor

public static ExecutorExtension<Executor> withCachedExecutor()

Create an ExecutorExtension with a default executor.

Returns:

a new ExecutorExtension.

withTestExecutor

public static ExecutorExtension<TestExecutor> withTestExecutor()

Create an ExecutorExtension with a TestExecutor.

executor() will return the TestExecutor to allow controlling the executor in tests.

Returns:

a new ExecutorExtension.

withExecutor

public static ExecutorExtension<Executor> withExecutor(java.util.function.Supplier<Executor> executorSupplier)

Create an ExecutorExtension with the specified executor.

Parameters:

executorSupplier - The Executor Supplier to use.

Returns:

a new ExecutorExtension.

withCachedExecutor

public static ExecutorExtension<Executor> withCachedExecutor(java.lang.String namePrefix)

Create an ExecutorExtension with a default executor, configured to prefix thread names with namePrefix.

Parameters:

namePrefix - the name to prefix thread names with.

Returns:

a new ExecutorExtension.

executor

public E executor()

Returns Executor created on the last call to beforeEach(ExtensionContext) ()}.

Returns:

Executor created on the last call to beforeEach(ExtensionContext) ()}. null if beforeEach(ExtensionContext) ()} has not been called yet.

beforeEach

public void beforeEach(org.junit.jupiter.api.extension.ExtensionContext context)

Specified by:

beforeEach in interface org.junit.jupiter.api.extension.BeforeEachCallback

afterEach

public void afterEach(org.junit.jupiter.api.extension.ExtensionContext context)
               throws java.util.concurrent.ExecutionException,
                      java.lang.InterruptedException

Specified by:

afterEach in interface org.junit.jupiter.api.extension.AfterEachCallback

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException