Skip to content

Commit 43a90ae

Browse files
committed
allow sending binary messages on iOS
1 parent f32aa84 commit 43a90ae

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

ios/MqttClient.m

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ @interface RCT_EXTERN_MODULE(MqttClient, NSObject)
1414

1515
RCT_EXTERN_METHOD(disconnect)
1616

17-
RCT_EXTERN_METHOD(publish:(NSString*)topic payload:(NSString*)payload resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject)
17+
RCT_EXTERN_METHOD(publish:(NSString*)topic payload:(NSArray*)payload resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject)
1818

1919
RCT_EXTERN_METHOD(subscribe:(NSString*)topic resolve:(RCTPromiseResolveBlock)resolve reject:(RCTPromiseRejectBlock)reject)
2020

ios/MqttClient.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -329,14 +329,14 @@ class MqttClient : RCTEventEmitter {
329329
}
330330

331331
@objc(publish:payload:resolve:reject:)
332-
func publish(topic: String, payload: String, resolve: RCTPromiseResolveBlock, reject: RCTPromiseRejectBlock) -> Void
332+
func publish(topic: String, payload: NSArray, resolve: RCTPromiseResolveBlock, reject: RCTPromiseRejectBlock) -> Void
333333
{
334334
os_log("MqttClient: publishing to %s", topic)
335335
guard let client = self.client else {
336336
reject("NO_CONNECTION", "no MQTT connection", nil)
337337
return
338338
}
339-
client.publish(CocoaMQTTMessage(topic: topic, string: payload))
339+
client.publish(CocoaMQTTMessage(topic: topic, payload: payload as! [UInt8], retained: true))
340340
resolve(nil)
341341
}
342342

0 commit comments

Comments
 (0)