Package org.apache.beam.it.gcp.pubsub.conditions

Package that contains reusable Pub/Sub conditions.

See: Description

Class Summary

Class	Description
PubsubMessagesCheck	ConditionCheck to validate if Pub/Sub has received a certain amount of messages.
PubsubMessagesCheck.Builder	Builder for PubsubMessagesCheck.

Package org.apache.beam.it.gcp.pubsub.conditions Description

Package that contains reusable Pub/Sub conditions.