(ctx context.Context, req pluginapi.ExecutorRequest)
| 433 | } |
| 434 | |
| 435 | func (a *rpcPluginAdapter) CountTokens(ctx context.Context, req pluginapi.ExecutorRequest) (pluginapi.ExecutorResponse, error) { |
| 436 | callbackID, closeCallback := a.openHostCallbackContext(ctx) |
| 437 | defer closeCallback() |
| 438 | return callPlugin[pluginapi.ExecutorResponse](ctx, a.client, pluginabi.MethodExecutorCountTokens, rpcExecutorRequest{ |
| 439 | ExecutorRequest: req, |
| 440 | HostCallbackID: callbackID, |
| 441 | }) |
| 442 | } |
| 443 | |
| 444 | func (a *rpcPluginAdapter) HttpRequest(ctx context.Context, req pluginapi.ExecutorHTTPRequest) (pluginapi.ExecutorHTTPResponse, error) { |
| 445 | callbackID, closeCallback := a.openHostCallbackContext(ctx) |
nothing calls this directly
no test coverage detected