Class TestExecutorResource<T extends ExecutorService>
- java.lang.Object
-
- org.junit.rules.ExternalResource
-
- org.apache.flink.testutils.executor.TestExecutorResource<T>
-
- All Implemented Interfaces:
org.junit.rules.TestRule
public class TestExecutorResource<T extends ExecutorService> extends org.junit.rules.ExternalResource
Resource which starts/stops anExecutorService
for testing purposes.
-
-
Constructor Summary
Constructors Constructor Description TestExecutorResource(Supplier<T> serviceFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
after()
protected void
before()
T
getExecutor()
-