仅在流结束后解析Promise
问题：仅在流结束后解析Promise是什么意思？
回答：仅在流结束后解析Promise是指在处理异步操作时，只有在流（例如网络请求、文件读取等）完全结束后才会解析Promise对象。Promise是一种用于处理异步操作的对象，它可以表示一个异步操作的最终完成或失败，并返回相应的结果或错误信息。
在某些情况下，我们希望在流结束后才执行后续的操作，以确保数据的完整性和准确性。这可以通过使用Promise的resolve和reject方法来实现。当流结束时，我们可以调用resolve方法来解析Promise，表示异步操作成功完成，并返回相应的结果。如果流出现错误或异常，我们可以调用reject方法来解析Promise，表示异步操作失败，并返回错误信息。
这种方式可以确保在处理异步操作时，只有在流完全结束后才会执行后续的操作，避免了数据不完整或不准确的情况。
在腾讯云的云计算平台中，可以使用云函数（Serverless Cloud Function）来实现仅在流结束后解析Promise的操作。云函数是一种无服务器的计算服务，可以在云端运行代码，无需关心服务器的搭建和维护。通过编写云函数，可以在流结束后解析Promise，并进行相应的处理。
推荐的腾讯云产品：云函数（Serverless Cloud Function） 产品介绍链接地址：https://cloud.tencent.com/product/scf
相关·内容
我对角(只是学习)很陌生，我正在努力理解下面的代码。在这段代码中(我从我在Github上看到的另一个应用程序中简化了它)，subscribe方法用参数resolve调用add方法(来自承诺)--所以我有几个问题：
不传递用于添加mehtod的参数，必须是“`Subscription”类型？，框架如何处理传递的resolve参数。我认为参数必须是订阅类型，框架调用它的<Subscription>.unsubscribe() .
const numbers: Observable<number> = interval(5000);
const takeFourNumbe
浏览 5提问于2022-07-21得票数 0
回答已采纳
为什么不能将promise转换为observable，然后在withLatestFrom中使用它。我不清楚，为什么这个问题不能解决。 of('')
.pipe(
withLatestFrom(from(myPromise)),
map((res) => {
console.log('does not resolve', res);
})
)
.subscribe();
浏览 26提问于2020-12-02得票数 2
回答已采纳
1回答
我有一个函数，里面有一个带有return的"then“函数。我希望将此返回添加到外部返回中。请参见代码： public async getAllWidgets(): Promise <Widget[]> {
let settings = new SettingsRepository(this.context, null);
let data: Widget[];
settings.CountryUrl().then(async(url) => {
var repositoryUserCountryUrl = new ListRepositor
浏览 9提问于2019-05-10得票数 1
回答已采纳
据我所知，你不能通过在生成器中yield a promise来获得promise。下面的测试证明了这一点。ret未定义： function* foo() {
const ret = yield Promise.resolve(50);
console.log(`ret is ${ret}`);
}
const fooGen = foo();
fooGen.next();
fooGen.next() 但我不明白为什么我可以在Redux saga中获得已解析的promise值。参见以下示例(jsfiddle：https://jsfiddle.net/vymgr7de/1/) /
浏览 4提问于2019-01-17得票数 2
回答已采纳
我尝试构造一个名为downloadTextPromise的promise来下载文件，然后在Promise.all()中读取文件内容。但是，我仍然无法读取Promise.all().then中的文件内容。
我怀疑downloadTextPromise是一个两步的promise，所以只有第一步(HTTP GET)被推入promises数组。但我几乎不知道如何修复它。
有什么提示吗？任何有效的解决方案都是受欢迎的，request-promise-native包不是强制性的。
我的代码如下：
const request = require("request-promise-native"
浏览 1提问于2017-06-22得票数 0
2回答
我对promise有个问题
我想获得所有类别和子类别(多级类别)使用promise。但是我不能得到多层次的承诺。我可以使用Promise.all(数组)获得第一个Promise，但不能获得子promise。
getChild: function(_cats){
var arrCat=[];
var that = this;
for (var i = 0, len = _cats.length; i < len; i++) {
var t = new Promise(function(resolve,reject){
var a = [];
浏览 1提问于2017-09-08得票数 1
假设我有这样的TS代码： import { concat, from, of } from 'rxjs';
import { mergeMap } from 'rxjs/operators';
const promise = (i: number) =>
new Promise<number>((resolve) => {
const delay = Math.floor(Math.random() * 1000);
setTimeout(() => {
console.log(`promise
浏览 17提问于2020-11-10得票数 1
回答已采纳
1回答
我正在尝试使用AWS Lambda中的promises，但遇到了一些问题。我使用的是typescript/nodejs；请参阅下面的代码
export function handler(event: any, context: any, callback: Function){
testFunction().then(data => callback(null, "success from promise"));
callback(null, "success");
}
export function testFunction()
浏览 5提问于2017-01-20得票数 3
回答已采纳
1回答
在Windows phone8.1 (WinRT)中，我从用户的document文件夹中抓取一个文件，并尝试将其读两遍。一次读取每一行，并获取总行的计数，以便跟踪进度。第二次实际解析数据。然而，在第二次遍历时，我得到了一个"File is not readable“类型错误。因此，我对正在发生的事情有一点了解，但并不是完全了解。我得到这个错误是因为文件的流已经在文件的末尾吗？我不能只从同一个文件中打开一个新的流，或者我必须关闭第一个流吗？
下面是我的代码：
public async Task UploadBerData(StorageFile file)
{
_csvParse
浏览 0提问于2015-02-11得票数 0
这是一个更一般的问题，但我只是不能用更一般的方式来写，所以我必须使用我正在处理的例子。 无论如何，我查看了async+await，但似乎Promise with resolve箭头函数不能用于此示例。那么，有没有可能重构这个函数并以这样一种方式调用代码:调用getFeaturesFromStream之后的代码不会在on('end')代码被调用之前被调用？ private features : FeatureObject[] = [];
getFeaturesFromStream() {
const url = 'http://localhost:19100/
浏览 22提问于2019-02-27得票数 1
回答已采纳
1回答
我创建了以下三个承诺，并等待它们，期望它们花费6000毫秒：
let PromiseOne = new Promise(resolve => {
setTimeout(() => {
resolve('Promise One');
}, 2000);
});
let PromiseTwo = new Promise(resolve => {
setTimeout(() => {
resolve('Promise Two');
}, 2000);
});
let PromiseThree = new
浏览 1提问于2022-10-25得票数 3
回答已采纳
我只想记录一个错误并跳过这一步，但有延迟和真正的typescript推断。 const fetch = () =>
Math.random() > 0.5
? Promise.resolve("Success")
: Promise.reject("Some error");
const x = timer(0, 1000).pipe(
mergeMap(() => fetch()),
catchError((err, caught) => {
console.log("Error:
浏览 12提问于2019-10-15得票数 1
回答已采纳
1回答
我正在尝试使用Apollo的graphql工具来简化graphql服务器。我想做延迟抓取，但不能像使用javascript类作为解析器时那样返回promise。
下面是我得到的信息：
模式
type Customer {
details: Contact!
addresses: [Address]!
}
extend type Query {
customers(first: Int = 0, next: Int = 50): [Customer]
customer(id: Int!): Customer
}
解析器
const
浏览 4提问于2017-08-04得票数 1
回答已采纳
我使用ioctl()从应用程序调用驱动程序函数。通过使用日志，我发现我的内核代码是首先执行的。例如,
在我的应用中
printf(“调用驱动程序”)；ioctl()；
在我的驱动里
printk(“调用驱动程序”)；
当我执行我的代码，它首先是打印“驱动程序调用”，然后“调用驱动程序”我有什么原因吗？
浏览 1提问于2012-12-31得票数 1
在下面的示例中，为什么在解析first之后会有另一个promise链接？即使在解析第一个promise时，我们也有来自fetch的响应对象。
var myImage = document.querySelector('img');
fetch('flowers.jpg').then(function(response) {
return response.blob();
}).then(function(myBlob) {
var objectURL = URL.createObjectURL(myBlob);
myImage.src = obje
浏览 0提问于2017-08-29得票数 0
1回答
假设我有一个如下的同步函数：
function sumTotal(items) {
return items.reduce((total, item) => item.price + total)
}
并且在这个“checkout”函数中包含一些异步Promise.all调用之后使用它
function checkout(items) {
return Promise.all([
getLatestOffers(),
getCustomerDetails('johndoe@gmail.com')
]).then(([offers, detail
浏览 1提问于2018-08-27得票数 0
2回答
在Promise.then中检查数据后，我想退出循环。我该怎么做呢？现在我有了infinity loop.Here的代码：
let my_break = 0
let page_id = 1
let p = Promise.resolve()
while(my_break===0) {
p = p.then(() => {
getReposData(name,page_id).then(data=>{
if (data.length===0){
浏览 0提问于2019-10-24得票数 0
我正在使用npm的big-json来绕过JSON.stringify()对大型嵌套对象的限制。 一旦对象被字符串化，我就会将它保存到文件系统中。 然而，这整个过程减慢了我的整体处理速度-我假设这与我现在可能正在等待一个流超时或在它关闭之前的某个东西有关。 这是我的代码： const fs = require('fs-extra');
const json = require('big-json');
function offlineSave(objArr){
return new Promise((resolve, reject) => {
浏览 9提问于2019-09-10得票数 0
回答已采纳
对于以下代码：-
let p1 = new Promise((resolve, reject) => {
setTimeout(() => {
console.log("one");
resolve("data1");
}, 8000)
})
let p2 = new Promise((resolve, reject) => {
setTimeout(() => {
console.log("two");
resolve("data2");
}, 5000
浏览 0提问于2021-04-23得票数 1
1回答
等待代码完成，等待/异步并承诺
、、、、
我正在尝试使用await/异步和Promise.all一起获取一些数组，然后继续使用代码，但是当我模拟代码中的延迟时，它似乎不起作用。我的代码在下面
async getAllTheUnits() {
// get all units
console.log('allunits called 1')
let unitRef = db.collection('units')
try {
let allUnitsSnapShot = await unitRef.get()
浏览 4提问于2022-08-03得票数 0
回答已采纳
1回答
我有一个样本，请看一下，如果我做得对的话， export const create = async ({ invitationList, testId }) => {
try {
const promises = invitationList.map(async invitationTo => {
return new Promise(async (resolve, reject) => {
const invitation = await InterviewSchedule({
invitationTo,
浏览 52提问于2021-01-18得票数 2
回答已采纳
1回答
我尝试从用户那里获取一张图像作为输入，并使用python对其进行处理，然后在node js中显示处理结果。为此，用户首先上传图像，然后我将其保存在uploads文件夹中。然后，python脚本获取该图像并对其进行处理，然后将其保存在相同的位置。最后，我显示新图像。我尝试过使用异步语句和promise，但它们似乎不起作用。 app.post("/image", function(req, res){
upload(req, res, (err)=> {
if(err){
res.render('upload', {
浏览 23提问于2020-07-03得票数 0
回答已采纳
1回答
效应器有没有比waitForTask更“原生”的方式？ import { createEffect } from 'effector'
const runTestTask = createEffect({
async handler (name) {
// Simulating long task
await new Promise(resolve => setTimeout(resolve, 10000));
return { name };
}
});
function waitForTask (c
浏览 17提问于2020-08-24得票数 0
1回答
在下面的代码中，当我调用func时，我得到了一个在3秒后解析的promise，它解析为另一个promise。然后，嵌套的promise在额外的3秒后解析为数字43。我的问题是，为什么console.log在6秒后返回res:43，而不是3秒后返回未解析的promise。I .then func2但I .then .then otherFunc
async function func(){
const val = func2().then((other)=>{console.log("res:"+other)})
}
async function func2(){
浏览 13提问于2018-10-09得票数 1
回答已采纳
2回答
我试图异步启动一个函数，但它是同步启动的。
#include <thread>
#include <future>
#include <vector>
#include <iostream>
#include <algorithm>
using namespace std;
std::future<int> setPromise()
{
auto promise = std::make_shared<std::promise<int>>();
auto future = prom
浏览 1提问于2018-09-19得票数 0
回答已采纳
2回答
我在Node.js中做的第一件事，就是编写一个AWS Lambda函数，我想在做任何其他事情之前检查用户的自定义属性是否有值。因为我被告知Promise是同步处理异步方法的方法，所以我写了这个函数：
var AWS = require('aws-sdk');
var s3 = new AWS.S3();
var cogId = new AWS.CognitoIdentityServiceProvider();
exports.handler = function (event, context) {
if (event != null)
{
浏览 1提问于2018-11-10得票数 1
1回答
写在承诺中存档
、、、
这里的函数创建了一堆文件，但没有写入它们。无论如何，如果我最终删除了Promise.all，并且根本不解析函数，它就会将数据写入文件。不管我想写什么，我可以评论一切，只写“你好世界”，它仍然不会写任何东西。问题很简单，为什么？
const writeSmilFiles = (smilInfo) => {
return new Promise ((resolve, reject) => {
const p1 = smilPartOne();
const p2 = smilPartTwo();
let promises = dataTypes.new.ca
浏览 3提问于2017-05-12得票数 0
回答已采纳
我正在读取一个带有groovy XmlParser的xml文件，例如：
def myXMLContent = new XmlParser().parse(new File("myFile.xml"))
但是我没有找到用于XmlParser的close方法。难道我不需要释放文件句柄吗？我在文档中没有找到任何关于这方面的东西。
浏览 1提问于2013-04-29得票数 2
回答已采纳
1回答
作为一个挑战，我已经用Java实现了一个基本的web服务器。当我打开原始的InputStream时，我立即进入阻塞读取，它将整个400字节的HTTP读入一个字节数组。这是可行的，但是我不会检查更多的数据，只需在发送响应后关闭套接字。
我想知道是否有更可靠的方法来做到这一点，以避免错过来自客户端的任何数据。我想一次读一个字节，直到read返回流的末尾。然而，它有时会在没有更多数据的情况下阻塞，令人困惑的是，JavaDocs for public abtract int InputStream.read()说：
If no byte is available because the end of
浏览 6提问于2012-03-03得票数 5
回答已采纳
我使用的是流0.30.0。我有一个返回promise的函数：
function process(callback:Function):Promise {
return new Promise((r,re) => callback)
}
Flow引发了一个错误，报错：
function process(callback:Function):Promise {
^^^^^^^ Promise. Application of polymorphic type needs <list of 1 argument&g
浏览 0提问于2016-08-03得票数 27
回答已采纳
我已经尝试使用带有多个麦克风的transcirbe_steaming_infinite.py模块。第一个是安装在我的电脑上的(Mac book pro)，另一个是外部的(Jabra EVOLVE 20)。通过音频MIDI设置，我设置了一个聚合设备选项(Jabra用于通道#1，mac用于通道#2)。
为了使用这些麦克风，我将ResumableMicrophoneStream._num_channels这样的代码修改为2，并在RecognitionConfig、audio_channel_count=2和enable_seperate_recognition_per_channel=True之后添
浏览 1提问于2020-03-30得票数 0
我如何写入节点通流，然后读取该数据？当我尝试时，代码挂起，好像没有发送任何数据。下面是一个很小的例子(在打字本中)：
const stream = new PassThrough();
stream.write('Test chunk.');
stream.end();
// Later
const chunks: Buffer[] = [];
const output = await new Promise<Buffer>((resolve, reject) => {
stream.on(&#
浏览 5提问于2022-08-08得票数 0
回答已采纳
1回答
我将XML数据作为字符串进行解析，我使用以下代码将XML字符串转换为inputsource：
StringReader reader1 = new StringReader( xmlstring);
InputSource inputSource1= new InputSource( reader );
并且我将输入源传递给
文档文档= builder.build(inputSource)；
我也想在另一个解析器类中使用相同的inputSource1，但我得到了流关闭。
我该如何处理这个问题，或者有没有其他方法可以将XML数据传递给解析器而不是文件？
浏览 1提问于2010-01-06得票数 0
回答已采纳
2回答
我试图读取和解析一个大型csv文件，对于每一行，我必须在操作完成后进行一些异步计算并增加计数器。因此，我创建了一个承诺p，并试图链接许多.then(xxx)，在csv阅读结束时，这是输出计数的最终.then(yyy)。
然而，这一数字加起来并不相加。但是如果我做了p = p.then(xxx)和p = p.then(yyy)，这个数字将加起来(对于较小的csv文件)，但有时我会面临内存泄漏(对于大型csv文件)。
我做错什么了吗？
var fs = require('fs')
const csv = require('fast-csv');
var Promis
浏览 1提问于2017-08-16得票数 0
回答已采纳
我正在探索Promise.all()的用法，但我不知道为什么它没有给我带来预期的结果。我试着一步一步地说明这一点。
让我们看看我的代码：
var p2 = 1337;
var p3 = new Promise((resolve, reject) => {
setTimeout(resolve, 2000, 'foo');
});
var apiCall = async () =>{
// to simulate a api call that will response after 5 sec
setTimeout(() => {r
浏览 12提问于2022-11-29得票数 0
回答已采纳
1回答
我有一个类，它维护一个名为write_stream的实例变量。这个write_stream变量使用新的写入流进行更新，目前我这样做： const fs = require('fs');
class Test {
constructor() {
this.write_stream = null;
}
...
set_write_stream(new_file_path) {
if (this.write_stream != null) {
this.write_stream.end();
}
浏览 20提问于2020-04-09得票数 2
回答已采纳
2回答
我创建了一个简单的类，它向服务器发送一个字符串，这两个类都使用Java进行通信。服务器读取客户端发送的内容，并使用另一个字符串进行响应。但是客户不能读到那个回应。
这是客户端类：
import java.io.IOException;
import java.net.Socket;
public class Client {
public static void main(String[] args) throws IOException {
Socket socket = new Socket("localhost", 8181);
浏览 4提问于2016-09-25得票数 0
回答已采纳
1回答
在下面的代码中，为什么promise resolved显示在promise being resolved之前
var p = protractor.promise.defer();
element(by.css("input.m-call-to-action")).click().then(function() {
console.log('promise being resolved');
p.fulfill(true);
});
browser.wait(function() {
浏览 5提问于2015-03-02得票数 2
回答已采纳
我见过有人这样做：
Promise.resolve().then(fn)
在很多地方，我都想知道为什么会这样？为什么他们不能直接打电话给fn？为什么要解析一个Promise然后调用一个fn
浏览 2提问于2018-06-02得票数 0
回答已采纳
我只是想做一个简单的异步函数，按计划运行。我刚从一个柜台开始。但是这个循环的行为与我想象的不同。
async function runCheckChats(){
while(true){
count++
console.log(`this loop is running`);
await new Promise(res => {
setInterval(() => {
count++
res(3);
}, 3000)
})
console.log(`count = ${count}
浏览 0提问于2020-02-21得票数 0
1回答
我正在构建一个应用程序，它从系统中的不同节点接收XMPP消息并对其进行处理。此应用程序的流量将会很高。因此，我实现了工作线程来进行处理。
因此，应用程序从套接字接收XMPP消息，并将其传递给工作线程，以便对收到的消息进行xml解析。每个线程都有单独的解析器上下文。
为了安全起见，我希望确保当我向工作线程传递消息时，它是一个完整的xmpp消息。希望得到您对该方法的宝贵建议。
浏览 2提问于2014-05-13得票数 0
3回答
第二个异步等待函数未调用
、、、
我正在尝试首先解压缩一个文件，然后等待解压缩文件完成，然后循环遍历每个文件并将其上传到S3存储桶。第一个函数unzipPromise运行良好，所有内容都被解压到正确的目录中，但是uploadS3Promise根本没有运行。我在这个过程中没有得到错误，它只是运行并解压缩文件，从来没有接触过uploadS3Promise函数。
function unzipInput(file, client, project_number, oldpath, newpath) {
path = `zips/${client}/${project_number}/${file}/`;
functio
浏览 0提问于2018-09-07得票数 0
我有一段这样的代码：
source$.pipe(
exhaustMap(input => ajaxPost1(input)), // ajaxPost1 returns ajaxObservable
tap(console.log), // can print HTTP response
exhaustMap(({result}) => ajaxPost2(result)), // ajaxPost2 returns promise
tap(console.log), // print nothing sometimes even if promis
浏览 10提问于2019-10-23得票数 0
1回答
我在我的机器上运行代码示例(安装了Node 5.8.0 )并获得下一个结果(参见代码示例之后)。
代码示例：
'use strict'
var p1 = Promise.resolve();
var p2 = Promise.resolve();
var p12 = Promise.all([p1, p2]);
var cb = function() {
console.log(p12);
}
setTimeout(cb, 0);
console.log(p1);
console.log(p2);
console.log(p12);
结果：
承诺{未定义}
承诺{
浏览 0提问于2016-03-19得票数 3
回答已采纳
我正在尝试为我的Mongoose模型创建一些测试，但我想不出如何让Jest/Mockgoose测试通过一个简短的查询/聚合管道(参见下面的第一个代码块)，我创建该管道是为了从一个集合中检索一个没有在另一个集合中引用的随机文档。
activitySchema.query.getUnused = function() {
return Activity.aggregate()
.lookup({
from: 'userActivity',
localField: '_id',
浏览 4提问于2017-04-16得票数 4
回答已采纳
我有这个JavaScript fetch函数
async getAllExpensesByUser() {
let reponse = await fetch("router.php/getAll");
console.log(reponse.json());
}
也尝试过
getAllExpensesByUser = async () => {
const response = await fetch("router.php/getAll");
if (response.ok) {
const jsonVa
浏览 0提问于2021-04-11得票数 0
我有如下的doSomething，doSomethingElse & finalHandler函数：
function doSomething() {
console.log('doSomething(): start');
return new Promise(function (resolve) {
setTimeout(function () {
console.log('doSomething(): end');
resolve();
}, 1000);
});
}
function doSo
浏览 0提问于2020-06-27得票数 2
2回答
我正在尝试解决NextJS应用程序构建过程中的一系列承诺，因为我在使用Promise.all时遇到网络错误，但由于某些原因，我在解决这些承诺时遇到了麻烦。 此代码可以工作，但不能与我的构建一起工作： const activityPlacesPromises = activityLocationIDs.map((id) =>
this.get(`places/${id}`)
);
const activityPlaces = await Promise.all(activityPlacesPromises);
console.log(activityPlaces); // R
浏览 9提问于2020-10-26得票数 0
回答已采纳
从下面的代码中，我试图在游戏对象从api循环填充其数据后解析promise，如果这是有意义的，但它仍然显示为空：
{
info: summoner,
matchIds: { << used for loop below
0: matchIds['matches'][0].matchId,
1: matchIds['matches'][1].matchId,
2: matchIds['matches'][2].ma
浏览 2提问于2017-03-05得票数 0
1回答
我有一个Firebase云函数，每天股市开盘时触发一次。似乎在运行的时候会产生20%的错误。
错误提示：“错误:函数崩溃超出了请求作用域，函数调用被中断。”
export async function cleanIntraweek() {
console.log(`cleanIntraweek() started`)
const min_date_key = moment().tz("America/New_York").subtract(7, 'day').format()
console.log(`min_date_key: ${min_da
浏览 3提问于2019-07-20得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
