(msgName: T, msg: ServiceType['msg'][T])
| 264 | } |
| 265 | |
| 266 | sendMsg<T extends keyof ServiceType['msg']>(msgName: T, msg: ServiceType['msg'][T]): SuperPromise<void, TsrpcError> { |
| 267 | this.logger.log('[SendMsg]', msgName, msg); |
| 268 | |
| 269 | if (!this._ws) { |
| 270 | throw new Error('Not connected') |
| 271 | } |
| 272 | |
| 273 | // GetService |
| 274 | let service = this.serviceMap.msgName2Service[msgName as string]; |
| 275 | if (!service) { |
| 276 | throw new Error('Invalid msg name: ' + msgName) |
| 277 | } |
| 278 | |
| 279 | // Encode |
| 280 | let buf = TransportDataUtil.encodeMsg(this.tsbuffer, service, msg); |
| 281 | |
| 282 | // Send Data |
| 283 | return new SuperPromise<void, TsrpcError>((rs, rj) => { |
| 284 | this._ws!.send(buf, e => { |
| 285 | e ? rj(e) : rs(); |
| 286 | }) |
| 287 | }) |
| 288 | } |
| 289 | } |
| 290 | |
| 291 | const defaultClientOptions: WsClientOptions<any> = { |
no test coverage detected