[ReactNative] NetInfo listener Map

This commit is contained in:
Eric Vicenti 2015-06-12 14:57:23 -07:00
parent 098a1163b1
commit 32f895a315
1 changed files with 15 additions and 9 deletions

View File

@ -11,6 +11,7 @@
*/
'use strict';
var Map = require('Map');
var NativeModules = require('NativeModules');
var Platform = require('Platform');
var RCTDeviceEventEmitter = require('RCTDeviceEventEmitter');
@ -140,30 +141,32 @@ type ConnectivityStateAndroid = $Enum<{
* ```
*/
var _subscriptions = {};
var _subscriptions = new Map();
var NetInfo = {
addEventListener: function (
eventName: ChangeEventName,
handler: Function
): void {
_subscriptions[String(handler)] = RCTDeviceEventEmitter.addListener(
var listener = RCTDeviceEventEmitter.addListener(
DEVICE_REACHABILITY_EVENT,
(appStateData) => {
handler(appStateData.network_reachability);
}
);
_subscriptions.set(handler, listener);
},
removeEventListener: function(
eventName: ChangeEventName,
handler: Function
): void {
if (!_subscriptions[String(handler)]) {
var listener = _subscriptions.get(handler);
if (!listener) {
return;
}
_subscriptions[String(handler)].remove();
_subscriptions[String(handler)] = null;
listener.remove();
_subscriptions.delete(handler);
},
fetch: function(): Promise {
@ -197,19 +200,20 @@ if (Platform.OS === 'ios') {
};
}
var _isConnectedSubscriptions = {};
var _isConnectedSubscriptions = new Map();
NetInfo.isConnected = {
addEventListener: function (
eventName: ChangeEventName,
handler: Function
): void {
_isConnectedSubscriptions[String(handler)] = (connection) => {
var listener = (connection) => {
handler(_isConnected(connection));
};
_isConnectedSubscriptions.set(handler, listener);
NetInfo.addEventListener(
eventName,
_isConnectedSubscriptions[String(handler)]
listener
);
},
@ -217,10 +221,12 @@ NetInfo.isConnected = {
eventName: ChangeEventName,
handler: Function
): void {
var listener = _isConnectedSubscriptions.get(handler);
NetInfo.removeEventListener(
eventName,
_isConnectedSubscriptions[String(handler)]
listener
);
_isConnectedSubscriptions.delete(handler);
},
fetch: function(): Promise {