(
options: {
readonly size: number
readonly concurrency?: number | undefined
readonly targetUtilization?: number | undefined
} | {
readonly minSize: number
readonly maxSize: number
readonly concurrency?: number | undefined
readonly targetUtilization?: number | undefined
readonly timeToLive: Duration.DurationInput
}
)
| 1228 | * @category protocol |
| 1229 | */ |
| 1230 | export const layerProtocolWorker = ( |
| 1231 | options: { |
| 1232 | readonly size: number |
| 1233 | readonly concurrency?: number | undefined |
| 1234 | readonly targetUtilization?: number | undefined |
| 1235 | } | { |
| 1236 | readonly minSize: number |
| 1237 | readonly maxSize: number |
| 1238 | readonly concurrency?: number | undefined |
| 1239 | readonly targetUtilization?: number | undefined |
| 1240 | readonly timeToLive: Duration.DurationInput |
| 1241 | } |
| 1242 | ): Layer.Layer<Protocol, WorkerError, Worker.PlatformWorker | Worker.Spawner> => |
| 1243 | Layer.scoped(Protocol, makeProtocolWorker(options)) |
| 1244 | |
| 1245 | /** |
| 1246 | * @since 1.0.0 |
nothing calls this directly
no test coverage detected
searching dependent graphs…