We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6042d6e commit 4c7bf99Copy full SHA for 4c7bf99
1 file changed
datafusion/core/tests/execution/coop.rs
@@ -794,9 +794,9 @@ async fn stream_yields(
794
let yielded = select! {
795
result = join_handle => {
796
match result {
797
- Ok(Pending) => Yielded::ReadyOrPending,
798
- Ok(Ready(Ok(_))) => Yielded::ReadyOrPending,
799
- Ok(Ready(Err(e))) => Yielded::Err(e),
+ Ok(Poll::Pending) => Yielded::ReadyOrPending,
+ Ok(Poll::Ready(Ok(_))) => Yielded::ReadyOrPending,
+ Ok(Poll::Ready(Err(e))) => Yielded::Err(e),
800
Err(_) => Yielded::Err(exec_datafusion_err!("join error")),
801
}
802
},
0 commit comments