等待函数回调时出现问题

Question

我有一个函数向服务器发送消息以获取答案，如果答案为真，我希望我的应用程序向用户发送错误。问题是我无法在我编写的 Fetch 函数中等待回调。这是将问题发送到服务器的功能。

async donglePaired(){

    if (Platform.OS !=='ios'){

        var pairedDevices = await BluetoothScanner.getPairedDevices();

        console.log('Sending........');

        let data={

            data:pairedDevices,

        };

        new Api().fetch("bluetoothCheck",{devices:JSON.stringify(data),userid:this.state.probe.UID},(result) => {

            if (!result.err) return false;

            console.log("Dongle already paired");

            return true;

            //logNetworkState

        });

    }

}

这是我写的 Api.fetch 函数

fetch(action,data,cb){

    let url=Config.URL+"?version="+Config.VERSION+"&action="+action;

    let post="";

    let formData=new FormData();

    for(let k in data) formData.append(k,data[k]);

    for(let k in data) post+="&"+k+"="+encodeURIComponent(data[k]).replace(/%20/g,'+');

    console.log(url+post);

    console.log(url);

    if (data.batch) console.log(data.batch);

    let sending=true;

    fetch(url,{

        method: 'post',

        body: formData

    })

    .then(function(response){

        if (true) return response.json();

        let txt=response.text();

        console.log(txt);

        return JSON.parse(txt);

    })

    .then(

        (result)=>{

            if (!sending) return;

            sending=false;

            console.log(JSON.stringify(result));

            if (cb) cb(result);

        },

        (error)=>{

            if (!sending) return;

            sending=false;

            console.log("fetch error");

            console.log(error);

            if (cb) cb();

        }

    );

    setTimeout(()=>{

        console.log("http timeout")

        if (!sending) return console.log("nothing to abort");

        if (cb) cb();

    },Config.HTTP_TIMEOUT*1000)

}

}

这是我等待第一个函数 donglePaired 的主要代码，如果 donglePaired 返回 true，我会向用户发送错误。

let donglePaired = await this.props.app.donglePaired();

    if (donglePaired) return this.props.app.setError("ERR_DONGLE");

问题是程序不等待 donglePaired，尽管有等待

Answer 1

您可以Promise.race()使用超时函数返回一个。fetch(action, data, cb) {  let url = Config.URL + "?version=" + Config.VERSION + "&action=" + action;  let post = "";  let formData = new FormData();  for (let k in data) formData.append(k, data[k]);  for (let k in data)    post += "&" + k + "=" + encodeURIComponent(data[k]).replace(/%20/g, "+");  console.log(url + post);  console.log(url);  if (data.batch) console.log(data.batch);  let sending = true;  return Promise.race([    fetch(url, {      method: "post",      body: formData    })      .then(res => res.json())      .then(result => {        if (!sending) return;        sending = false;        return result;      }),    sleep(Config.HTTP_TIMEOUT * 1000)  ]);}const sleep = ms => new Promise((_, rej) => setTimeout(rej("TIMEOUT"), ms));它要么返回值，要么拒绝TIMEOUT，或者拒绝 fetch 的错误然后看起来donglePaired像这样。我用一个包裹它try / catchasync donglePaired() {  if (Platform.OS !== "ios") {    var pairedDevices = await BluetoothScanner.getPairedDevices();    console.log("Sending........");    let data = {      data: pairedDevices    };    try {      let result = await new Api().fetch("bluetoothCheck", {        devices: JSON.stringify(data),        userid: this.state.probe.UID      });      if (!result.err) return false;      console.log("Dongle already paired");      return true;      //logNetworkState    } catch (err) {      console.log(err);    }  }}

Answer 2

这些片段应该让您了解如何等待回调发送至 APIasync function remove_configuration(filename) {const data = { filename };const options = {    method: 'POST',    headers: {        'Content-Type': 'application/json'    },    body: JSON.stringify(data)};    await fetch('/delete', options);}只是检索数据async function display() {            let response = await fetch('/get-available-configurations')        let data = await response.json(); // JSON or Text what do you prefer         // do something with data}

Answer 3

你这里的代码不合适let donglePaired = await this.props.app.donglePaired();if (donglePaired) return this.props.app.setError("ERR_DONGLE");异步函数无法正常返回值，除非它是 Promise 请参阅下面我的简单演示！async function test() {  const result = await asyncRequest()  return result}function asyncRequest() {  return new Promise((resolve, reject) => {    setTimeout(() => {      resolve('success')    }, 2000)  })}test().then((data) => {  console.log(data)})

Answer 4

一种可能性是删除async并将其更改为：   donglePaired() {        return new Promise( function(resolve, reject) {             if (Platform.OS !=='ios'){              var pairedDevices = await BluetoothScanner.getPairedDevices();              console.log('Sending........');              let data={                  data:pairedDevices,              };              new Api().fetch("bluetoothCheck",{devices:JSON.stringify(data),userid:this.state.probe.UID},(result) => {                  if (!result.err) reject(false);                  console.log("Dongle already paired");                  resolve(true);                  //logNetworkState              });            }            reject(false);        });       }和：this.props.app.donglePaired().then( (response) => {   // do something here, this will only run if the response is true});