bulk-cdk-core-extract/io.airbyte.cdk.read/ResourceAcquirer

ResourceAcquirer

@Singleton

class ResourceAcquirer(val acquierers: List<Resource<*>>)(source)

Constructors

ResourceAcquirer

constructor(acquierers: List<Resource<*>>)

@Inject

constructor(cr: ConcurrencyResource, sr: SocketResource)

Properties

val acquierers: List<Resource<*>>

Functions

fun tryAcquire(requested: List<ResourceType>): Map<ResourceType, Resource.Acquired>?

tryAcquireResource

fun tryAcquireResource(requested: ResourceType): Resource.Acquired?