diff options
| author | Aaron O'Mullan <aaron.omullan@gmail.com> | 2021-04-11 07:05:43 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-04-11 07:05:43 +0200 |
| commit | 29eca72fea4f1e160a8d76d2ebda26e2c48b9658 (patch) | |
| tree | be8db9d2253a1f64bda23a01b035932b6dc5d34b /core/ops_bin.rs | |
| parent | 8aa0d5f96ed418e21efb99967f1f6b7fea0dc87f (diff) | |
core: avoid async op future reboxing to bundle PromiseId (#10123)
Diffstat (limited to 'core/ops_bin.rs')
| -rw-r--r-- | core/ops_bin.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/ops_bin.rs b/core/ops_bin.rs index b19782449..c4c57f4b9 100644 --- a/core/ops_bin.rs +++ b/core/ops_bin.rs @@ -132,11 +132,11 @@ where p: OpPayload, b: Option<ZeroCopyBuf>| -> Op { + let pid = p.promise_id; let min_arg: u32 = p.deserialize().unwrap(); let fut = op_fn(state.clone(), min_arg, b) - .map(move |result| serialize_bin_result(result, state)); - let temp = Box::pin(fut); - Op::Async(temp) + .map(move |result| (pid, serialize_bin_result(result, state))); + Op::Async(Box::pin(fut)) }, ) } |