/rust/registry/src/index.crates.io-1949cf8c6b5b557f/futures-util-0.3.31/src/stream/mod.rs
Line | Count | Source |
1 | | //! Asynchronous streams. |
2 | | //! |
3 | | //! This module contains: |
4 | | //! |
5 | | //! - The [`Stream`] trait, for objects that can asynchronously produce a |
6 | | //! sequence of values. |
7 | | //! - The [`StreamExt`] and [`TryStreamExt`] trait, which provides adapters for |
8 | | //! chaining and composing streams. |
9 | | //! - Top-level stream constructors like [`iter`](iter()) which creates a |
10 | | //! stream from an iterator. |
11 | | |
12 | | #[cfg(feature = "alloc")] |
13 | | pub use futures_core::stream::{BoxStream, LocalBoxStream}; |
14 | | pub use futures_core::stream::{FusedStream, Stream, TryStream}; |
15 | | |
16 | | // Extension traits and combinators |
17 | | |
18 | | #[allow(clippy::module_inception)] |
19 | | mod stream; |
20 | | pub use self::stream::{ |
21 | | All, Any, Chain, Collect, Concat, Count, Cycle, Enumerate, Filter, FilterMap, FlatMap, Flatten, |
22 | | Fold, ForEach, Fuse, Inspect, Map, Next, NextIf, NextIfEq, Peek, PeekMut, Peekable, Scan, |
23 | | SelectNextSome, Skip, SkipWhile, StreamExt, StreamFuture, Take, TakeUntil, TakeWhile, Then, |
24 | | Unzip, Zip, |
25 | | }; |
26 | | |
27 | | #[cfg(feature = "std")] |
28 | | pub use self::stream::CatchUnwind; |
29 | | |
30 | | #[cfg(feature = "alloc")] |
31 | | pub use self::stream::Chunks; |
32 | | |
33 | | #[cfg(feature = "alloc")] |
34 | | pub use self::stream::ReadyChunks; |
35 | | |
36 | | #[cfg(feature = "sink")] |
37 | | #[cfg_attr(docsrs, doc(cfg(feature = "sink")))] |
38 | | pub use self::stream::Forward; |
39 | | |
40 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
41 | | #[cfg(feature = "alloc")] |
42 | | pub use self::stream::{ |
43 | | BufferUnordered, Buffered, FlatMapUnordered, FlattenUnordered, ForEachConcurrent, |
44 | | }; |
45 | | |
46 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
47 | | #[cfg(feature = "sink")] |
48 | | #[cfg_attr(docsrs, doc(cfg(feature = "sink")))] |
49 | | #[cfg(feature = "alloc")] |
50 | | pub use self::stream::{ReuniteError, SplitSink, SplitStream}; |
51 | | |
52 | | mod try_stream; |
53 | | pub use self::try_stream::{ |
54 | | try_unfold, AndThen, ErrInto, InspectErr, InspectOk, IntoStream, MapErr, MapOk, OrElse, TryAll, |
55 | | TryAny, TryCollect, TryConcat, TryFilter, TryFilterMap, TryFlatten, TryFold, TryForEach, |
56 | | TryNext, TrySkipWhile, TryStreamExt, TryTakeWhile, TryUnfold, |
57 | | }; |
58 | | |
59 | | #[cfg(feature = "io")] |
60 | | #[cfg_attr(docsrs, doc(cfg(feature = "io")))] |
61 | | #[cfg(feature = "std")] |
62 | | pub use self::try_stream::IntoAsyncRead; |
63 | | |
64 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
65 | | #[cfg(feature = "alloc")] |
66 | | pub use self::try_stream::{ |
67 | | TryBufferUnordered, TryBuffered, TryFlattenUnordered, TryForEachConcurrent, |
68 | | }; |
69 | | |
70 | | #[cfg(feature = "alloc")] |
71 | | pub use self::try_stream::{TryChunks, TryChunksError, TryReadyChunks, TryReadyChunksError}; |
72 | | |
73 | | // Primitive streams |
74 | | |
75 | | mod iter; |
76 | | pub use self::iter::{iter, Iter}; |
77 | | |
78 | | mod repeat; |
79 | | pub use self::repeat::{repeat, Repeat}; |
80 | | |
81 | | mod repeat_with; |
82 | | pub use self::repeat_with::{repeat_with, RepeatWith}; |
83 | | |
84 | | mod empty; |
85 | | pub use self::empty::{empty, Empty}; |
86 | | |
87 | | mod once; |
88 | | pub use self::once::{once, Once}; |
89 | | |
90 | | mod pending; |
91 | | pub use self::pending::{pending, Pending}; |
92 | | |
93 | | mod poll_fn; |
94 | | pub use self::poll_fn::{poll_fn, PollFn}; |
95 | | |
96 | | mod poll_immediate; |
97 | | pub use self::poll_immediate::{poll_immediate, PollImmediate}; |
98 | | |
99 | | mod select; |
100 | | pub use self::select::{select, Select}; |
101 | | |
102 | | mod select_with_strategy; |
103 | | pub use self::select_with_strategy::{select_with_strategy, PollNext, SelectWithStrategy}; |
104 | | |
105 | | mod unfold; |
106 | | pub use self::unfold::{unfold, Unfold}; |
107 | | |
108 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
109 | | #[cfg(feature = "alloc")] |
110 | | mod futures_ordered; |
111 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
112 | | #[cfg(feature = "alloc")] |
113 | | pub use self::futures_ordered::FuturesOrdered; |
114 | | |
115 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
116 | | #[cfg(feature = "alloc")] |
117 | | pub mod futures_unordered; |
118 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
119 | | #[cfg(feature = "alloc")] |
120 | | #[doc(inline)] |
121 | | pub use self::futures_unordered::FuturesUnordered; |
122 | | |
123 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
124 | | #[cfg(feature = "alloc")] |
125 | | pub mod select_all; |
126 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
127 | | #[cfg(feature = "alloc")] |
128 | | #[doc(inline)] |
129 | | pub use self::select_all::{select_all, SelectAll}; |
130 | | |
131 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
132 | | #[cfg(feature = "alloc")] |
133 | | mod abortable; |
134 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
135 | | #[cfg(feature = "alloc")] |
136 | | pub use crate::abortable::{AbortHandle, AbortRegistration, Abortable, Aborted}; |
137 | | #[cfg_attr(target_os = "none", cfg(target_has_atomic = "ptr"))] |
138 | | #[cfg(feature = "alloc")] |
139 | | pub use abortable::abortable; |
140 | | |
141 | | // Just a helper function to ensure the streams we're returning all have the |
142 | | // right implementations. |
143 | 723 | pub(crate) fn assert_stream<T, S>(stream: S) -> S |
144 | 723 | where |
145 | 723 | S: Stream<Item = T>, |
146 | | { |
147 | 723 | stream |
148 | 723 | } futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::expr::plan::TopLevelExpr, anyhow::Error>, futures_util::stream::iter::Iter<core::iter::adapters::map::Map<alloc::vec::into_iter::IntoIter<surrealdb_core::expr::plan::TopLevelExpr>, core::result::Result<surrealdb_core::expr::plan::TopLevelExpr, anyhow::Error>::Ok>>> Line | Count | Source | 143 | 35 | pub(crate) fn assert_stream<T, S>(stream: S) -> S | 144 | 35 | where | 145 | 35 | S: Stream<Item = T>, | 146 | | { | 147 | 35 | stream | 148 | 35 | } |
Unexecuted instantiation: futures_util::stream::assert_stream::<core::pin::Pin<alloc::boxed::Box<dyn core::future::future::Future<Output = core::result::Result<alloc::vec::Vec<surrealdb_core::val::Value>, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, futures_util::stream::iter::Iter<alloc::vec::into_iter::IntoIter<core::pin::Pin<alloc::boxed::Box<dyn core::future::future::Future<Output = core::result::Result<alloc::vec::Vec<surrealdb_core::val::Value>, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::pin::Pin<alloc::boxed::Box<dyn core::future::future::Future<Output = core::result::Result<surrealdb_core::val::Value, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, futures_util::stream::iter::Iter<alloc::vec::into_iter::IntoIter<core::pin::Pin<alloc::boxed::Box<dyn core::future::future::Future<Output = core::result::Result<surrealdb_core::val::Value, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<alloc::vec::Vec<alloc::vec::Vec<u8>>, anyhow::Error>, futures_util::stream::try_stream::MapErr<futures_util::stream::try_stream::MapErr<surrealdb_core::kvs::scanner::Scanner<alloc::vec::Vec<u8>>, <surrealdb_core::err::Error as core::convert::From<surrealdb_core::kvs::err::Error>>::from>, <surrealdb_core::err::Error as core::convert::Into<anyhow::Error>>::into>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<alloc::vec::Vec<alloc::vec::Vec<u8>>, surrealdb_core::err::Error>, futures_util::stream::try_stream::MapErr<surrealdb_core::kvs::scanner::Scanner<alloc::vec::Vec<u8>>, <surrealdb_core::err::Error as core::convert::From<surrealdb_core::kvs::err::Error>>::from>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<alloc::vec::Vec<surrealdb_core::val::Value>, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::buffered::Buffered<futures_util::stream::iter::Iter<alloc::vec::into_iter::IntoIter<core::pin::Pin<alloc::boxed::Box<dyn core::future::future::Future<Output = core::result::Result<alloc::vec::Vec<surrealdb_core::val::Value>, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>>>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<alloc::vec::Vec<(alloc::vec::Vec<u8>, alloc::vec::Vec<u8>)>, anyhow::Error>, futures_util::stream::try_stream::MapErr<futures_util::stream::try_stream::MapErr<surrealdb_core::kvs::scanner::Scanner<(alloc::vec::Vec<u8>, alloc::vec::Vec<u8>)>, <surrealdb_core::err::Error as core::convert::From<surrealdb_core::kvs::err::Error>>::from>, <surrealdb_core::err::Error as core::convert::Into<anyhow::Error>>::into>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<alloc::vec::Vec<(alloc::vec::Vec<u8>, alloc::vec::Vec<u8>)>, surrealdb_core::err::Error>, futures_util::stream::try_stream::MapErr<surrealdb_core::kvs::scanner::Scanner<(alloc::vec::Vec<u8>, alloc::vec::Vec<u8>)>, <surrealdb_core::err::Error as core::convert::From<surrealdb_core::kvs::err::Error>>::from>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::path::Path, object_store::Error>, futures_util::stream::once::Once<<alloc::sync::Arc<dyn object_store::ObjectStore> as object_store::ObjectStoreExt>::delete::{closure#0}::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::val::Value, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::buffered::Buffered<futures_util::stream::iter::Iter<alloc::vec::into_iter::IntoIter<core::pin::Pin<alloc::boxed::Box<dyn core::future::future::Future<Output = core::result::Result<surrealdb_core::val::Value, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>>>>> futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::return::ReturnPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Line | Count | Source | 143 | 6 | pub(crate) fn assert_stream<T, S>(stream: S) -> S | 144 | 6 | where | 145 | 6 | S: Stream<Item = T>, | 146 | | { | 147 | 6 | stream | 148 | 6 | } |
Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::info::user::UserInfoPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::info::index::IndexInfoPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::info::table::TableInfoPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::info::database::DatabaseInfoPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::current_value_source::CurrentValueSource as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::ifelse::IfElsePlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::let_plan::LetPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sequence::SequencePlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::recursion::RecursionOp as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::info::root::RootInfoPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::info::namespace::NamespaceInfoPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::shuffle::RandomShuffle as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::expr::ExprPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Line | Count | Source | 143 | 26 | pub(crate) fn assert_stream<T, S>(stream: S) -> S | 144 | 26 | where | 145 | 26 | S: Stream<Item = T>, | 146 | | { | 147 | 26 | stream | 148 | 26 | } |
Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sleep::SleepPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::foreach::ForeachPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::full_sort::Sort as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::knn_topk::KnnTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::full_sort::SortByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::external::ExternalSort as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::explain::ExplainPlan as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::topk::SortTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::topk::SortTopKByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::empty::Empty<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::unfold::Unfold<(alloc::vec::Vec<alloc::sync::Arc<dyn surrealdb_core::exec::ExecOperator>>, surrealdb_core::exec::context::ExecutionContext, usize, core::option::Option<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>>), <surrealdb_core::exec::operators::union::Union as surrealdb_core::exec::ExecOperator>::execute::{closure#0}, <surrealdb_core::exec::operators::union::Union as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::shuffle::RandomShuffle as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::sort::shuffle::RandomShuffle as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::sort::shuffle::RandomShuffle as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::full_sort::Sort as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::sort::full_sort::Sort as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::sort::full_sort::Sort as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::knn_topk::KnnTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::knn_topk::KnnTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::knn_topk::KnnTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::full_sort::SortByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::sort::full_sort::SortByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::sort::full_sort::SortByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::external::ExternalSort as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::sort::external::ExternalSort as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::sort::external::ExternalSort as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::topk::SortTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::sort::topk::SortTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::sort::topk::SortTopK as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<futures_util::stream::once::Once<<surrealdb_core::exec::operators::sort::topk::SortTopKByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>, <surrealdb_core::exec::operators::sort::topk::SortTopKByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#1}::{closure#0}, <surrealdb_core::exec::operators::sort::topk::SortTopKByKey as surrealdb_core::exec::ExecOperator>::execute::{closure#1}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::filter_map::FilterMap<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::filter::Filter as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}, <surrealdb_core::exec::operators::filter::Filter as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::map::Map<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::split::Split as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::then::Then<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::project_value::ProjectValue as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}, <surrealdb_core::exec::operators::project_value::ProjectValue as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Line | Count | Source | 143 | 1 | pub(crate) fn assert_stream<T, S>(stream: S) -> S | 144 | 1 | where | 145 | 1 | S: Stream<Item = T>, | 146 | | { | 147 | 1 | stream | 148 | 1 | } |
Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::then::Then<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::fetch::Fetch as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}, <surrealdb_core::exec::operators::fetch::Fetch as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::then::Then<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::compute::Compute as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}, <surrealdb_core::exec::operators::compute::Compute as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::then::Then<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::project::Project as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}, <surrealdb_core::exec::operators::project::Project as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>, futures_util::stream::stream::then::Then<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<surrealdb_core::exec::ValueBatch, surrealdb_core::expr::ControlFlow>> + core::marker::Send>>, <surrealdb_core::exec::operators::project::SelectProject as surrealdb_core::exec::ExecOperator>::execute::{closure#0}::{closure#0}, <surrealdb_core::exec::operators::project::SelectProject as surrealdb_core::exec::ExecOperator>::execute::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<futures_util::stream::try_stream::try_unfold::TryUnfold<(std::fs::File, std::path::PathBuf, u64), object_store::local::chunked_stream::{closure#0}::{closure#1}, object_store::util::maybe_spawn_blocking<object_store::local::chunked_stream::{closure#0}::{closure#1}::{closure#0}, core::option::Option<(bytes::bytes::Bytes, (std::fs::File, std::path::PathBuf, u64))>>::{closure#0}>, object_store::Error>, futures_util::stream::once::Once<object_store::local::chunked_stream::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::ObjectMeta, object_store::Error>, futures_util::stream::iter::Iter<alloc::vec::into_iter::IntoIter<core::result::Result<object_store::ObjectMeta, object_store::Error>>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::ObjectMeta, object_store::Error>, futures_util::stream::iter::Iter<core::iter::adapters::flatten::FlatMap<walkdir::IntoIter, core::option::Option<core::result::Result<object_store::ObjectMeta, object_store::Error>>, <object_store::local::LocalFileSystem>::list_with_maybe_offset::{closure#0}>>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::ObjectMeta, object_store::Error>, core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<object_store::ObjectMeta, object_store::Error>> + core::marker::Send>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::ObjectMeta, object_store::Error>, futures_util::stream::try_stream::try_filter::TryFilter<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<object_store::ObjectMeta, object_store::Error>> + core::marker::Send>>, futures_util::future::ready::Ready<bool>, <object_store::memory::InMemory as object_store::ObjectStore>::list_with_offset::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::ObjectMeta, object_store::Error>, futures_util::stream::try_stream::try_unfold::TryUnfold<(core::iter::adapters::flatten::FlatMap<walkdir::IntoIter, core::option::Option<core::result::Result<object_store::ObjectMeta, object_store::Error>>, <object_store::local::LocalFileSystem>::list_with_maybe_offset::{closure#0}>, alloc::collections::vec_deque::VecDeque<core::result::Result<object_store::ObjectMeta, object_store::Error>>), <object_store::local::LocalFileSystem>::list_with_maybe_offset::{closure#1}, <object_store::local::LocalFileSystem>::list_with_maybe_offset::{closure#1}::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::ObjectMeta, object_store::Error>, futures_util::future::future::IntoStream<futures_util::future::ready::Ready<core::result::Result<object_store::ObjectMeta, object_store::Error>>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<bytes::bytes::Bytes, object_store::Error>, futures_util::stream::once::Once<futures_util::future::ready::Ready<core::result::Result<bytes::bytes::Bytes, object_store::Error>>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<bytes::bytes::Bytes, object_store::Error>, futures_util::stream::unfold::Unfold<(core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<bytes::bytes::Bytes, object_store::Error>> + core::marker::Send>>, bytes::bytes_mut::BytesMut, bool, usize), <object_store::chunked::ChunkedStore as object_store::ObjectStore>::get_opts::{closure#0}::{closure#0}, <object_store::chunked::ChunkedStore as object_store::ObjectStore>::get_opts::{closure#0}::{closure#0}::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<bytes::bytes::Bytes, object_store::Error>, core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<bytes::bytes::Bytes, object_store::Error>> + core::marker::Send>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<bytes::bytes::Bytes, object_store::Error>, futures_util::stream::try_stream::try_unfold::TryUnfold<(std::fs::File, std::path::PathBuf, u64), object_store::local::chunked_stream::{closure#0}::{closure#1}, object_store::util::maybe_spawn_blocking<object_store::local::chunked_stream::{closure#0}::{closure#1}::{closure#0}, core::option::Option<(bytes::bytes::Bytes, (std::fs::File, std::path::PathBuf, u64))>>::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<bytes::bytes::Bytes, object_store::Error>, futures_util::stream::try_stream::try_flatten::TryFlatten<futures_util::stream::once::Once<object_store::local::chunked_stream::{closure#0}>>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<bytes::bytes::Bytes, object_store::Error>, futures_util::stream::stream::then::Then<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<bytes::bytes::Bytes, object_store::Error>> + core::marker::Send>>, futures_util::future::future::Then<object_store::throttle::sleep::{closure#0}, futures_util::future::ready::Ready<core::result::Result<bytes::bytes::Bytes, object_store::Error>>, object_store::throttle::throttle_stream<bytes::bytes::Bytes, object_store::Error, object_store::throttle::throttle_get::{closure#0}>::{closure#0}::{closure#0}>, object_store::throttle::throttle_stream<bytes::bytes::Bytes, object_store::Error, object_store::throttle::throttle_get::{closure#0}>::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::path::Path, object_store::Error>, futures_util::stream::once::Once<<object_store::local::LocalFileSystem as object_store::ObjectStoreExt>::delete::{closure#0}::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::path::Path, object_store::Error>, futures_util::stream::once::Once<<object_store::memory::InMemory as object_store::ObjectStoreExt>::delete::{closure#0}::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::path::Path, object_store::Error>, core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<object_store::path::Path, object_store::Error>> + core::marker::Send>>> Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::path::Path, object_store::Error>, futures_util::stream::stream::map::Map<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<object_store::path::Path, object_store::Error>> + core::marker::Send>>, <object_store::memory::InMemory as object_store::ObjectStore>::delete_stream::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<core::result::Result<object_store::path::Path, object_store::Error>, futures_util::stream::stream::buffered::Buffered<futures_util::stream::stream::map::Map<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<object_store::path::Path, object_store::Error>> + core::marker::Send>>, <object_store::local::LocalFileSystem as object_store::ObjectStore>::delete_stream::{closure#0}>>>Unexecuted instantiation: futures_util::stream::assert_stream::<object_store::util::maybe_spawn_blocking<<object_store::local::LocalFileSystem as object_store::ObjectStore>::delete_stream::{closure#0}::{closure#0}, object_store::path::Path>::{closure#0}, futures_util::stream::stream::map::Map<core::pin::Pin<alloc::boxed::Box<dyn futures_core::stream::Stream<Item = core::result::Result<object_store::path::Path, object_store::Error>> + core::marker::Send>>, <object_store::local::LocalFileSystem as object_store::ObjectStore>::delete_stream::{closure#0}>>Unexecuted instantiation: futures_util::stream::assert_stream::<_, _> futures_util::stream::assert_stream::<core::result::Result<surrealdb_core::expr::plan::TopLevelExpr, anyhow::Error>, futures_util::stream::iter::Iter<core::iter::adapters::map::Map<alloc::vec::into_iter::IntoIter<surrealdb_core::expr::plan::TopLevelExpr>, core::result::Result<surrealdb_core::expr::plan::TopLevelExpr, anyhow::Error>::Ok>>> Line | Count | Source | 143 | 655 | pub(crate) fn assert_stream<T, S>(stream: S) -> S | 144 | 655 | where | 145 | 655 | S: Stream<Item = T>, | 146 | | { | 147 | 655 | stream | 148 | 655 | } |
|