Skip to content

Commit 6be70b8

Browse files
feat(mqtt): app-325 Remove mqtt patch with the new library version
1 parent b9f0bd3 commit 6be70b8

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

src/index.tsx

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,8 @@
1-
import { NativeEventEmitter, NativeModules } from 'react-native';
1+
import {
2+
EmitterSubscription,
3+
NativeEventEmitter,
4+
NativeModules,
5+
} from 'react-native';
26

37
const { MqttClient: MqttClientImpl } = NativeModules;
48

@@ -184,16 +188,16 @@ export class MqttClient {
184188
* @function addListener
185189
*/
186190
addListener(eventName: string, listener: ListenerFunction) {
187-
eventBridge.addListener(eventName, listener);
191+
return eventBridge.addListener(eventName, listener);
188192
}
189193

190194
/**
191195
* Unlistens for a given event from this client.
192196
*
193197
* @function removeListener
194198
*/
195-
removeListener(eventName: string, listener: ListenerFunction) {
196-
eventBridge.removeListener(eventName, listener);
199+
removeListener(subscription: EmitterSubscription) {
200+
subscription.remove();
197201
}
198202
}
199203

0 commit comments

Comments
 (0)