servers-scheduler/karya.servers.scheduler.usecases.external/WorkerService

WorkerService

class WorkerService @Inject constructor(processTask: ProcessTask)

Service class responsible for processing tasks from a receive channel.

Constructors

Link copied to clipboard
@Inject
constructor(processTask: ProcessTask)

Creates an instance of WorkerService with the specified dependencies.

Types

Link copied to clipboard
object Companion : Logging

Functions

Link copied to clipboard
suspend fun invoke(channel: ReceiveChannel<Task>)

Invokes the worker service to process tasks from the given channel.