[BUG] If Device A publishes again after initial load, it disconnects from Device B about react-native-google-nearby-messages HOT 5 OPEN

let meObj = {};

const TextInput = () => {

  const onSubmitEditing = async (text) => {
    meObj.text = text;
    await publish(JSON.stringify(meObj));
  };

  const [value, onChangeText] = React.useState('Useless Placeholder');

  return (
    <TextInput
      style={{ height: 40, borderColor: 'gray', borderWidth: 1 , color: 'black'}}
      onChangeText={text => onChangeText(text)}
      onSubmitEditing = {(event) => (onSubmitEditing(event.nativeEvent.text))}
      value={value}
    />
  );
};

export default function App() {
  const [nearbyMessage, setNearbyMessage] = useState('');
  const [textMessage, setTextMessage] = useState('');

  useNearbyErrorCallback(
    useCallback((kind, message) => {
      Alert.alert(kind, message);
    }, []),
  );

  const _connect = useCallback(async () => {
    console.log('Connecting...');
    await connect({
      apiKey: API_KEY,
      discoveryModes: ['broadcast', 'scan'],
      discoveryMediums: ['ble'],
    });
    console.log('Connected!');
    return () => disconnect();
  }, []);

  const _publish = useCallback(async () => {
    const deviceName = await getDeviceName();
    meObj.deviceName = deviceName;
    console.log(`Publishing "${deviceName}"...`);
    await publish(JSON.stringify(meObj));
    console.log(`Published "${deviceName}"!`);
  }, []);

  const _subscribe = useCallback(async () => {
    console.log('Subscribing...');
    await subscribe(
      (m) => {
        m = JSON.parse(m);
        setNearbyMessage(m.deviceName);
        setTextMessage(m.text);
        console.log(`Found: ${JSON.stringify(m)}`);
      },
      (m) => {
        setNearbyMessage('');
        setTextMessage('');
        console.log(`Lost: ${JSON.stringify(m)}`);
      },
    );
    console.log('Subscribed!');
  }, []);

  const _checkPermissions = useCallback(async () => {
    const permission = await checkBluetoothPermission();
    const available = await checkBluetoothAvailability();
    Alert.alert(
      'Bluetooth Permissions:',
      `Granted: ${permission}, Available: ${available}`,
    );
  }, []);

  useEffect(() => {
    const start = async () => {
      try {
        await _checkPermissions();

        await _connect();
        await _subscribe();
        await _publish();
      } catch (e) {
        Alert.alert(
          'Unknown error occured while connecting!',
          JSON.stringify(e.message ?? e),
        );
      }
    };

    start();
    return () => disconnect();
  }, [_connect, _subscribe, _publish, _checkPermissions]);

  return (
    <View style={styles.container}>
      <Text style={styles.welcome}>☆GoogleNearbyMessages example☆</Text>
      {TextInput()}
      <Text style={styles.welcome}>Nearby Message:</Text>
      <Text style={styles.instructions}>{nearbyMessage}</Text>
      <Text style={styles.welcome}>Text Message:</Text>
      <Text style={styles.instructions}>{textMessage}</Text>
    </View>
  );
}