Package org.apache.beam.sdk.io.gcp.pubsublite.internal

Interface ManagedFactory<T extends AutoCloseable>

All Superinterfaces:

AutoCloseable, Serializable

All Known Implementing Classes:

ManagedFactoryImpl

public interface ManagedFactory<T extends AutoCloseable>
extends AutoCloseable, Serializable

A ManagedFactory produces instances and tears down any produced instances when it is itself closed.

close() should never be called on produced instances.

Method Summary

Modifier and Type	Method	Description
T	create(SubscriptionPartition subscriptionPartition)

Methods inherited from interface java.lang.AutoCloseable

close

Method Details

create

T create(SubscriptionPartition subscriptionPartition)