diff options
| author | bors <bors@rust-lang.org> | 2024-02-10 07:15:15 +0000 |
|---|---|---|
| committer | bors <bors@rust-lang.org> | 2024-02-10 07:15:15 +0000 |
| commit | 757b8efed44eacbbc6baf4a393f77d23d5be90c8 (patch) | |
| tree | 3d1898c476ccb02da378740f1440ebf590084fcb /library/core/src | |
| parent | 68125c72d389060fe9aaee8d87ebd834f417c9fc (diff) | |
| parent | 540be28f6c2571e7be3ab3936b62635fa0d3caf3 (diff) | |
| download | rust-757b8efed44eacbbc6baf4a393f77d23d5be90c8.tar.gz rust-757b8efed44eacbbc6baf4a393f77d23d5be90c8.zip | |
Auto merge of #120712 - compiler-errors:async-closures-harmonize, r=oli-obk
Harmonize `AsyncFn` implementations, make async closures conditionally impl `Fn*` traits This PR implements several changes to the built-in and libcore-provided implementations of `Fn*` and `AsyncFn*` to address two problems: 1. async closures do not implement the `Fn*` family traits, leading to breakage: https://crater-reports.s3.amazonaws.com/pr-120361/index.html 2. *references* to async closures do not implement `AsyncFn*`, as a consequence of the existing blanket impls of the shape `AsyncFn for F where F: Fn, F::Output: Future`. In order to fix (1.), we implement `Fn` traits appropriately for async closures. It turns out that async closures can: * always implement `FnOnce`, meaning that they're drop-in compatible with `FnOnce`-bound combinators like `Option::map`. * conditionally implement `Fn`/`FnMut` if they have no captures, which means that existing usages of async closures should *probably* work without breakage (crater checking this: https://github.com/rust-lang/rust/pull/120712#issuecomment-1930587805). In order to fix (2.), we make all of the built-in callables implement `AsyncFn*` via built-in impls, and instead adjust the blanket impls for `AsyncFn*` provided by libcore to match the blanket impls for `Fn*`.
Diffstat (limited to 'library/core/src')
| -rw-r--r-- | library/core/src/ops/async_function.rs | 51 |
1 files changed, 37 insertions, 14 deletions
diff --git a/library/core/src/ops/async_function.rs b/library/core/src/ops/async_function.rs index c5a8303a75c..d6b06ffb7fc 100644 --- a/library/core/src/ops/async_function.rs +++ b/library/core/src/ops/async_function.rs @@ -65,44 +65,67 @@ pub trait AsyncFnOnce<Args: Tuple> { mod impls { use super::{AsyncFn, AsyncFnMut, AsyncFnOnce}; - use crate::future::Future; use crate::marker::Tuple; #[unstable(feature = "async_fn_traits", issue = "none")] - impl<F: Fn<A>, A: Tuple> AsyncFn<A> for F + impl<A: Tuple, F: ?Sized> AsyncFn<A> for &F where - <F as FnOnce<A>>::Output: Future, + F: AsyncFn<A>, { - type CallFuture<'a> = <F as FnOnce<A>>::Output where Self: 'a; + type CallFuture<'a> = F::CallFuture<'a> where Self: 'a; extern "rust-call" fn async_call(&self, args: A) -> Self::CallFuture<'_> { - self.call(args) + F::async_call(*self, args) } } #[unstable(feature = "async_fn_traits", issue = "none")] - impl<F: FnMut<A>, A: Tuple> AsyncFnMut<A> for F + impl<A: Tuple, F: ?Sized> AsyncFnMut<A> for &F where - <F as FnOnce<A>>::Output: Future, + F: AsyncFn<A>, { - type CallMutFuture<'a> = <F as FnOnce<A>>::Output where Self: 'a; + type CallMutFuture<'a> = F::CallFuture<'a> where Self: 'a; extern "rust-call" fn async_call_mut(&mut self, args: A) -> Self::CallMutFuture<'_> { - self.call_mut(args) + F::async_call(*self, args) } } #[unstable(feature = "async_fn_traits", issue = "none")] - impl<F: FnOnce<A>, A: Tuple> AsyncFnOnce<A> for F + impl<'a, A: Tuple, F: ?Sized> AsyncFnOnce<A> for &'a F where - <F as FnOnce<A>>::Output: Future, + F: AsyncFn<A>, { - type CallOnceFuture = <F as FnOnce<A>>::Output; + type Output = F::Output; + type CallOnceFuture = F::CallFuture<'a>; - type Output = <<F as FnOnce<A>>::Output as Future>::Output; + extern "rust-call" fn async_call_once(self, args: A) -> Self::CallOnceFuture { + F::async_call(self, args) + } + } + + #[unstable(feature = "async_fn_traits", issue = "none")] + impl<A: Tuple, F: ?Sized> AsyncFnMut<A> for &mut F + where + F: AsyncFnMut<A>, + { + type CallMutFuture<'a> = F::CallMutFuture<'a> where Self: 'a; + + extern "rust-call" fn async_call_mut(&mut self, args: A) -> Self::CallMutFuture<'_> { + F::async_call_mut(*self, args) + } + } + + #[unstable(feature = "async_fn_traits", issue = "none")] + impl<'a, A: Tuple, F: ?Sized> AsyncFnOnce<A> for &'a mut F + where + F: AsyncFnMut<A>, + { + type Output = F::Output; + type CallOnceFuture = F::CallMutFuture<'a>; extern "rust-call" fn async_call_once(self, args: A) -> Self::CallOnceFuture { - self.call_once(args) + F::async_call_mut(self, args) } } } |
