(command: Command, resp: RespVersions)
| 174 | // POLICIES extends CommandPolicies |
| 175 | > extends EventEmitter { |
| 176 | static #createCommand(command: Command, resp: RespVersions) { |
| 177 | const transformReply = getTransformReply(command, resp); |
| 178 | |
| 179 | return async function (this: ProxyCluster, ...args: Array<unknown>) { |
| 180 | const parser = new BasicCommandParser(this._self._keyPrefix); |
| 181 | command.parseCommand(parser, ...args); |
| 182 | |
| 183 | return this._self._execute( |
| 184 | parser.firstKey, |
| 185 | command.IS_READ_ONLY, |
| 186 | this._commandOptions, |
| 187 | (client, opts) => client._executeCommand(command, parser, opts, transformReply) |
| 188 | ); |
| 189 | }; |
| 190 | } |
| 191 | |
| 192 | static #createModuleCommand(command: Command, resp: RespVersions) { |
| 193 | const transformReply = getTransformReply(command, resp); |
nothing calls this directly
no test coverage detected