diff --git a/examples/with-mqtt-js/app/page.tsx b/examples/with-mqtt-js/app/page.tsx index 4a60ade92e955..7e92779608d22 100644 --- a/examples/with-mqtt-js/app/page.tsx +++ b/examples/with-mqtt-js/app/page.tsx @@ -5,18 +5,15 @@ import type { MqttClient } from "mqtt"; import useMqtt from "@/lib/useMqtt"; export default function Home() { - const [incommingMessages, setIncommingMessages] = useState([]); + const [incomingMessages, setIncomingMessages] = useState([]); const addMessage = (message: any) => { - setIncommingMessages((incommingMessages) => [ - ...incommingMessages, - message, - ]); + setIncomingMessages((incomingMessages) => [...incomingMessages, message]); }; const clearMessages = () => { - setIncommingMessages(() => []); + setIncomingMessages(() => []); }; - const incommingMessageHandlers = useRef([ + const incomingMessageHandlers = useRef([ { topic: "topic1", handler: (msg: string) => { @@ -36,7 +33,7 @@ export default function Home() { password: process.env.NEXT_PUBLIC_MQTT_PASSWORD, clientId: process.env.NEXT_PUBLIC_MQTT_CLIENTID, }, - topicHandlers: incommingMessageHandlers.current, + topicHandlers: incomingMessageHandlers.current, onConnectedHandler: (client) => setMqttClient(client), }); @@ -52,11 +49,11 @@ export default function Home() { return (

Subscribed Topics

- {incommingMessageHandlers.current.map((i) => ( + {incomingMessageHandlers.current.map((i) => (

{i.topic}

))} -

Incomming Messages:

- {incommingMessages.map((m) => ( +

Incoming Messages:

+ {incomingMessages.map((m) => (

{m.payload.toString()}

))}