( name: TName, payload: RuntimeHostRequestMap[TName], )
| 451 | } |
| 452 | |
| 453 | function getHostForRequest<TName extends RuntimeHostRequestName>( |
| 454 | name: TName, |
| 455 | payload: RuntimeHostRequestMap[TName], |
| 456 | ) { |
| 457 | const sessionPath = getPersistedSessionPath(getRequestSessionPath(name, payload)) |
| 458 | if (!shouldUseThreadHost(name, payload)) { |
| 459 | return serviceHost |
| 460 | } |
| 461 | |
| 462 | const existingHost = sessionPath ? hostByAlias.get(sessionPath) : null |
| 463 | if (existingHost) { |
| 464 | return existingHost |
| 465 | } |
| 466 | |
| 467 | const host = createHostConnection('thread', sessionPath ?? `thread-${hosts.size}`) |
| 468 | rememberHostAlias(host, sessionPath) |
| 469 | return host |
| 470 | } |
| 471 | |
| 472 | export async function invokeRuntimeHost<TName extends RuntimeHostRequestName>( |
| 473 | name: TName, |
no test coverage detected