(ctx context.Context, req pluginapi.ExecutorRequest)
| 424 | } |
| 425 | |
| 426 | func (a *rpcPluginAdapter) Execute(ctx context.Context, req pluginapi.ExecutorRequest) (pluginapi.ExecutorResponse, error) { |
| 427 | callbackID, closeCallback := a.openHostCallbackContext(ctx) |
| 428 | defer closeCallback() |
| 429 | return callPlugin[pluginapi.ExecutorResponse](ctx, a.client, pluginabi.MethodExecutorExecute, rpcExecutorRequest{ |
| 430 | ExecutorRequest: req, |
| 431 | HostCallbackID: callbackID, |
| 432 | }) |
| 433 | } |
| 434 | |
| 435 | func (a *rpcPluginAdapter) CountTokens(ctx context.Context, req pluginapi.ExecutorRequest) (pluginapi.ExecutorResponse, error) { |
| 436 | callbackID, closeCallback := a.openHostCallbackContext(ctx) |
nothing calls this directly
no test coverage detected