Not able to write to request.write about qlik-sse HOT 6 CLOSED

hmm, you're using async/promise which I haven't tried at all. It could be a race condition where the end is called and stream closed before your promises have resolved. Try moving the line https://github.com/miralemd/qlik-sse/blob/master/lib/index.js#L29 last into your own function, or test write without any use of async await.

from qlik-sse.

As @miralemd suggested, when using await the request.end() will get called too early. I resolved the issue for myself by adding an async property to the function config that drives a conditional request.end(). https://github.com/RobWunderlich/qlik-sse/commit/be4bc04ab3ca655bed5f9a2f0c76d5ee054d87eb
@miralemd do you want to accept a PR for this? Or is this too specialized?

from qlik-sse.

fixed by 233e014

from qlik-sse.

@RobWunderlich & @miralemd Thanks for the update. My code still does not seem to want to handle using async. Here is a super easy example which still has request.end() calling too early. Any ideas?

function Test(request) {
  function waitUntil(i) {
    return new Promise(function(resolve, reject){
        setTimeout(() => {
          resolve(i);
        }, 500);
    });
  }
  request.on('data', async function (bundle) {
    console.log('data');
    let list = [];
    for(let i = 0; i < 10; i++) {
       console.log(i);
       let resp = await waitUntil(i);
       list.push(resp);
    }
    console.log('writing...');
    request.write({ "rows": [{ "duals": [{ "strData": list.toString() }] }] });
  });
}

from qlik-sse.

@rileymd88 The async detection expects your primary function to be marked async. So make it "async function Test(request)"

from qlik-sse.

@RobWunderlich Ahh ok that worked! I had to also adjust my code at the end and write request.end() after request.write(...)

from qlik-sse.