(messageId: string)
| 49 | } |
| 50 | |
| 51 | async stop(messageId: string): Promise<StreamingData | null> { |
| 52 | const data = this.dataMap.get(messageId) |
| 53 | if (data?.aiService) { |
| 54 | await data.aiService.stopStreaming() |
| 55 | } |
| 56 | return this.finish(messageId) |
| 57 | } |
| 58 | |
| 59 | async stopAll(): Promise<StreamingData[]> { |
| 60 | const messageIds = Array.from(this.dataMap.keys()) |
no test coverage detected