diff --git a/index.ts b/index.ts index c083ea0..a8972e2 100755 --- a/index.ts +++ b/index.ts @@ -14,8 +14,7 @@ import { randomWave } from '@/utils/randomWave'; import MqttService from './services/MqttService'; const mqttService = new MqttService(); -// 无需await -mqttService.start(); +await mqttService.start(); const spinner = ora({ discardStdin: false, diff --git a/services/MqttService.ts b/services/MqttService.ts index 4aaa9a7..eac43ff 100644 --- a/services/MqttService.ts +++ b/services/MqttService.ts @@ -84,7 +84,7 @@ export default class MqttService { }); mqttClient.on('message', (topic, message) => { const msg: MqttMessage = JSON.parse(message.toString()); - console.log('message:', msg); + // console.log('message:', msg); const method = this[msg.type as keyof MqttService] as (topic: string, message: MqttMessage) => void; if (typeof method === 'function') {