anoop4real / flutter_mqtt Goto Github PK

class PayloadGiver {
  final mqttStream = StreamController<String>();

  void payloadGiver(String subscribeTopic) {
    if (mqttInitComplete == true) {
      print('Subscribing to $subscribeTopic');
      // Not a wildcard topic
//    client.subscribe(subscribeTopic2, MqttQos.atMostOnce);
      client.subscribe(subscribeTopic, MqttQos.atMostOnce);
      client.updates.listen((List<MqttReceivedMessage<MqttMessage>> c) {
        final MqttPublishMessage recMess = c[0].payload;
        final pt =
            MqttPublishPayload.bytesToStringAsString(recMess.payload.message);

        print('The payload is : $pt');

        mqttStream.sink.add(pt);
      });
    }
  }

StreamBuilder<String>(
                      stream: mqttStream,
                      builder: (context, snapshot) {
//                        if (!snapshot.hasData) return Text('No Data');
//                        if (snapshot.connectionState == ConnectionState.waiting)
//                          print("Still Waiting for Data");
//                        print('Currently, I have: ' + snapshot.data);
                        if (snapshot.data == 'true')
                          return SwitchCardOn();
                        else if (snapshot.data == 'false') {
                          print(
                              "I recieved false but did not build the widget");
                          return SwitchCardOff();
                        } else
                          return Text('Waiting');
                      }),