Package org.apache.beam.sdk.io.gcp.pubsub

Interface TestPubsub.PollingAssertion

Enclosing class:
TestPubsub
public static interface TestPubsub.PollingAssertion

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    waitForUpTo(Duration timeoutDuration)