async function pushDataToClient()

in lambda/streamConsumer/streamConsumer.js [78:93]


async function pushDataToClient(connectionId, endpointURL, feed) {
  try {
    const apigwManagementApi = new AWS.ApiGatewayManagementApi({
      apiVersion: "2018-11-29",
      endpoint: endpointURL,
    })
    console.log("pushToConnection : " + connectionId + " feed  : " + JSON.stringify(feed))
    var testfeed="Test feed"
    var resp = await apigwManagementApi
      .postToConnection({ ConnectionId: connectionId, Data: JSON.stringify(feed) })
      .promise()
    return resp;
  } catch (err) {
    return err;
  }
}