Package io.github.flink.gcp.connector.base.lifecycle

Interface BoundedShutdown.TerminationWait

Enclosing class:
BoundedShutdown
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface BoundedShutdown.TerminationWait
The client's own bounded wait, satisfied by e.g. Publisher::awaitTermination.

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    await(long timeout, TimeUnit unit)