await pushDataToClient()

in lambda/streamConsumer/streamConsumer.js [46:65]

• 19 lines of code
• 1 McCabe index (conditional complexity)

            await pushDataToClient(conn, endpoint, feed)
          })
        )
      }
    })
  )
  const response = {
    statusCode: 200,
    body: JSON.stringify("StreamConsumer - Succeeded publishing"),
  }
  return response
}
// scan for connections in the sparse GSI-2
async function findAllConnections() {
  try {
    var params = {
      TableName: tableName,
      IndexName: "GSI-2",
      ProjectionExpression: "#PK, CLIENT, ENDPOINT",
      ExpressionAttributeNames: {