greptimedb/trait.impl/futures_core/stream/trait.Stream.js

(function() {
    var implementors = Object.fromEntries([["common_recordbatch",[["impl Stream for <a class=\"struct\" href=\"common_recordbatch/adapter/struct.AsyncRecordBatchStreamAdapter.html\" title=\"struct common_recordbatch::adapter::AsyncRecordBatchStreamAdapter\">AsyncRecordBatchStreamAdapter</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/adapter/struct.DfRecordBatchStreamAdapter.html\" title=\"struct common_recordbatch::adapter::DfRecordBatchStreamAdapter\">DfRecordBatchStreamAdapter</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/adapter/struct.RecordBatchStreamAdapter.html\" title=\"struct common_recordbatch::adapter::RecordBatchStreamAdapter\">RecordBatchStreamAdapter</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/struct.EmptyRecordBatchStream.html\" title=\"struct common_recordbatch::EmptyRecordBatchStream\">EmptyRecordBatchStream</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/struct.MemoryTrackedStream.html\" title=\"struct common_recordbatch::MemoryTrackedStream\">MemoryTrackedStream</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/struct.SendableRecordBatchMapper.html\" title=\"struct common_recordbatch::SendableRecordBatchMapper\">SendableRecordBatchMapper</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/struct.SimpleRecordBatchStream.html\" title=\"struct common_recordbatch::SimpleRecordBatchStream\">SimpleRecordBatchStream</a>"],["impl Stream for <a class=\"struct\" href=\"common_recordbatch/util/struct.ChainedRecordBatchStream.html\" title=\"struct common_recordbatch::util::ChainedRecordBatchStream\">ChainedRecordBatchStream</a>"],["impl&lt;S: Stream&lt;Item = <a class=\"type\" href=\"common_recordbatch/error/type.Result.html\" title=\"type common_recordbatch::error::Result\">Result</a>&lt;<a class=\"struct\" href=\"common_recordbatch/recordbatch/struct.RecordBatch.html\" title=\"struct common_recordbatch::recordbatch::RecordBatch\">RecordBatch</a>&gt;&gt; + <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html\" title=\"trait core::marker::Unpin\">Unpin</a>&gt; Stream for <a class=\"struct\" href=\"common_recordbatch/struct.RecordBatchStreamWrapper.html\" title=\"struct common_recordbatch::RecordBatchStreamWrapper\">RecordBatchStreamWrapper</a>&lt;S&gt;"],["impl&lt;T, E&gt; Stream for <a class=\"struct\" href=\"common_recordbatch/adapter/struct.RecordBatchStreamTypeAdapter.html\" title=\"struct common_recordbatch::adapter::RecordBatchStreamTypeAdapter\">RecordBatchStreamTypeAdapter</a>&lt;T, E&gt;<div class=\"where\">where\n    T: Stream&lt;Item = <a class=\"enum\" href=\"https://doc.rust-lang.org/nightly/core/result/enum.Result.html\" title=\"enum core::result::Result\">Result</a>&lt;<a class=\"struct\" href=\"common_recordbatch/struct.DfRecordBatch.html\" title=\"struct common_recordbatch::DfRecordBatch\">DfRecordBatch</a>, E&gt;&gt;,\n    E: <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/error/trait.Error.html\" title=\"trait core::error::Error\">Error</a> + <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/marker/trait.Send.html\" title=\"trait core::marker::Send\">Send</a> + <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/marker/trait.Sync.html\" title=\"trait core::marker::Sync\">Sync</a> + 'static,</div>"]]],["file_engine",[["impl Stream for <a class=\"struct\" href=\"file_engine/query/struct.FileToScanRegionStream.html\" title=\"struct file_engine::query::FileToScanRegionStream\">FileToScanRegionStream</a>"]]],["frontend",[["impl Stream for <a class=\"struct\" href=\"frontend/stream_wrapper/struct.CancellableStreamWrapper.html\" title=\"struct frontend::stream_wrapper::CancellableStreamWrapper\">CancellableStreamWrapper</a>"]]],["index",[["impl Stream for <a class=\"struct\" href=\"index/inverted_index/create/sort/merge_stream/struct.MergeSortedStream.html\" title=\"struct index::inverted_index::create::sort::merge_stream::MergeSortedStream\">MergeSortedStream</a>"]]],["log_store",[["impl Stream for <a class=\"struct\" href=\"log_store/kafka/consumer/struct.Consumer.html\" title=\"struct log_store::kafka::consumer::Consumer\">Consumer</a>"]]],["mito2",[["impl Stream for <a class=\"struct\" href=\"mito2/read/stream/struct.ConvertBatchStream.html\" title=\"struct mito2::read::stream::ConvertBatchStream\">ConvertBatchStream</a>"],["impl&lt;S&gt; Stream for <a class=\"struct\" href=\"mito2/read/scan_util/struct.SplitRecordBatchStream.html\" title=\"struct mito2::read::scan_util::SplitRecordBatchStream\">SplitRecordBatchStream</a>&lt;S&gt;<div class=\"where\">where\n    S: Stream&lt;Item = <a class=\"type\" href=\"mito2/error/type.Result.html\" title=\"type mito2::error::Result\">Result</a>&lt;RecordBatch&gt;&gt; + <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html\" title=\"trait core::marker::Unpin\">Unpin</a>,</div>"]]],["promql",[["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/scalar_calculate/struct.ScalarCalculateStream.html\" title=\"struct promql::extension_plan::scalar_calculate::ScalarCalculateStream\">ScalarCalculateStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.AbsentStream.html\" title=\"struct promql::extension_plan::AbsentStream\">AbsentStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.EmptyMetricStream.html\" title=\"struct promql::extension_plan::EmptyMetricStream\">EmptyMetricStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.HistogramFoldStream.html\" title=\"struct promql::extension_plan::HistogramFoldStream\">HistogramFoldStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.InstantManipulateStream.html\" title=\"struct promql::extension_plan::InstantManipulateStream\">InstantManipulateStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.RangeManipulateStream.html\" title=\"struct promql::extension_plan::RangeManipulateStream\">RangeManipulateStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.SeriesDivideStream.html\" title=\"struct promql::extension_plan::SeriesDivideStream\">SeriesDivideStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.SeriesNormalizeStream.html\" title=\"struct promql::extension_plan::SeriesNormalizeStream\">SeriesNormalizeStream</a>"],["impl Stream for <a class=\"struct\" href=\"promql/extension_plan/struct.UnionDistinctOnStream.html\" title=\"struct promql::extension_plan::UnionDistinctOnStream\">UnionDistinctOnStream</a>"]]],["query",[["impl Stream for <a class=\"struct\" href=\"query/part_sort/struct.PartSortStream.html\" title=\"struct query::part_sort::PartSortStream\">PartSortStream</a>"],["impl Stream for <a class=\"struct\" href=\"query/range_select/plan/struct.RangeSelectStream.html\" title=\"struct query::range_select::plan::RangeSelectStream\">RangeSelectStream</a>"],["impl Stream for <a class=\"struct\" href=\"query/window_sort/struct.WindowedSortStream.html\" title=\"struct query::window_sort::WindowedSortStream\">WindowedSortStream</a>"],["impl&lt;F: <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/ops/function/trait.FnOnce.html\" title=\"trait core::ops::function::FnOnce\">FnOnce</a>() + <a class=\"trait\" href=\"https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html\" title=\"trait core::marker::Unpin\">Unpin</a>&gt; Stream for <a class=\"struct\" href=\"query/metrics/struct.OnDone.html\" title=\"struct query::metrics::OnDone\">OnDone</a>&lt;F&gt;"]]],["servers",[["impl Stream for <a class=\"struct\" href=\"servers/grpc/flight/struct.FlightRecordBatchStream.html\" title=\"struct servers::grpc::flight::FlightRecordBatchStream\">FlightRecordBatchStream</a>"],["impl Stream for <a class=\"struct\" href=\"servers/grpc/flight/struct.PutRecordBatchRequestStream.html\" title=\"struct servers::grpc::flight::PutRecordBatchRequestStream\">PutRecordBatchRequestStream</a>"]]],["table",[["impl Stream for <a class=\"struct\" href=\"table/table/numbers/struct.NumbersStream.html\" title=\"struct table::table::numbers::NumbersStream\">NumbersStream</a>"],["impl Stream for <a class=\"struct\" href=\"table/table/scan/struct.StreamWithMetricWrapper.html\" title=\"struct table::table::scan::StreamWithMetricWrapper\">StreamWithMetricWrapper</a>"],["impl Stream for <a class=\"struct\" href=\"table/test_util/memtable/struct.MemtableStream.html\" title=\"struct table::test_util::memtable::MemtableStream\">MemtableStream</a>"]]]]);
    if (window.register_implementors) {
        window.register_implementors(implementors);
    } else {
        window.pending_implementors = implementors;
    }
})()
//{"start":57,"fragment_lengths":[3354,207,222,245,178,727,1746,983,420,550]}