| @@ -927,7 +927,6 @@ private: | |||||
| device->listeners.call ([source, &data] (auto& l) { l.propertySubscriptionDataReceived (source, data); }); | device->listeners.call ([source, &data] (auto& l) { l.propertySubscriptionDataReceived (source, data); }); | ||||
| PropertyReplyHeader header; | PropertyReplyHeader header; | ||||
| header.extended["subscribeId"] = subscribeId; | |||||
| const auto headerBytes = Encodings::jsonTo7BitText (header.toVarCondensed()); | const auto headerBytes = Encodings::jsonTo7BitText (header.toVarCondensed()); | ||||
| detail::MessageTypeUtils::send (device->concreteBufferOutput, | detail::MessageTypeUtils::send (device->concreteBufferOutput, | ||||
| @@ -1192,6 +1191,9 @@ private: | |||||
| if (! primed.isValid()) | if (! primed.isValid()) | ||||
| return; | return; | ||||
| // TODO(reuk) this isn't ideal, make subscription/request handling more robust | |||||
| primed.token.release(); | |||||
| detail::PropertyHostUtils::send (concreteBufferOutput, | detail::PropertyHostUtils::send (concreteBufferOutput, | ||||
| options.getFunctionBlock().firstGroup, | options.getFunctionBlock().firstGroup, | ||||
| detail::MessageMeta::Meta<Message::PropertySubscribe>::subID2, | detail::MessageMeta::Meta<Message::PropertySubscribe>::subID2, | ||||