blob: d7bad81143aa14dc13b61afd8fcb40828844ea65 [file] [log] [blame]
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><meta name="generator" content="rustdoc"><meta name="description" content="Wraps a type so that it implements [`Load`] and returns a constant load metric."><meta name="keywords" content="rust, rustlang, rust-lang, Constant"><title>Constant in tower::load - Rust</title><link rel="preload" as="font" type="font/woff2" crossorigin href="../../SourceSerif4-Regular.ttf.woff2"><link rel="preload" as="font" type="font/woff2" crossorigin href="../../FiraSans-Regular.woff2"><link rel="preload" as="font" type="font/woff2" crossorigin href="../../FiraSans-Medium.woff2"><link rel="preload" as="font" type="font/woff2" crossorigin href="../../SourceCodePro-Regular.ttf.woff2"><link rel="preload" as="font" type="font/woff2" crossorigin href="../../SourceSerif4-Bold.ttf.woff2"><link rel="preload" as="font" type="font/woff2" crossorigin href="../../SourceCodePro-Semibold.ttf.woff2"><link rel="stylesheet" href="../../normalize.css"><link rel="stylesheet" href="../../rustdoc.css" id="mainThemeStyle"><link rel="stylesheet" href="../../ayu.css" disabled><link rel="stylesheet" href="../../dark.css" disabled><link rel="stylesheet" href="../../light.css" id="themeStyle"><script id="default-settings" ></script><script src="../../storage.js"></script><script defer src="sidebar-items.js"></script><script defer src="../../main.js"></script><noscript><link rel="stylesheet" href="../../noscript.css"></noscript><link rel="alternate icon" type="image/png" href="../../favicon-16x16.png"><link rel="alternate icon" type="image/png" href="../../favicon-32x32.png"><link rel="icon" type="image/svg+xml" href="../../favicon.svg"></head><body class="rustdoc struct"><!--[if lte IE 11]><div class="warning">This old browser is unsupported and will most likely display funky things.</div><![endif]--><nav class="mobile-topbar"><button class="sidebar-menu-toggle">&#9776;</button><a class="sidebar-logo" href="../../tower/index.html"><div class="logo-container"><img class="rust-logo" src="../../rust-logo.svg" alt="logo"></div></a><h2></h2></nav><nav class="sidebar"><a class="sidebar-logo" href="../../tower/index.html"><div class="logo-container"><img class="rust-logo" src="../../rust-logo.svg" alt="logo"></div></a><h2 class="location"><a href="#">Constant</a></h2><div class="sidebar-elems"><section><h3><a href="#implementations">Methods</a></h3><ul class="block"><li><a href="#method.new">new</a></li></ul><h3><a href="#trait-implementations">Trait Implementations</a></h3><ul class="block"><li><a href="#impl-Debug-for-Constant%3CT%2C%20M%3E">Debug</a></li><li><a href="#impl-Load-for-Constant%3CT%2C%20M%3E">Load</a></li><li><a href="#impl-Service%3CRequest%3E-for-Constant%3CS%2C%20M%3E">Service&lt;Request&gt;</a></li><li><a href="#impl-Stream-for-Constant%3CD%2C%20M%3E">Stream</a></li><li><a href="#impl-Unpin-for-Constant%3CT%2C%20M%3E">Unpin</a></li></ul><h3><a href="#synthetic-implementations">Auto Trait Implementations</a></h3><ul class="block"><li><a href="#impl-RefUnwindSafe-for-Constant%3CT%2C%20M%3E">RefUnwindSafe</a></li><li><a href="#impl-Send-for-Constant%3CT%2C%20M%3E">Send</a></li><li><a href="#impl-Sync-for-Constant%3CT%2C%20M%3E">Sync</a></li><li><a href="#impl-UnwindSafe-for-Constant%3CT%2C%20M%3E">UnwindSafe</a></li></ul><h3><a href="#blanket-implementations">Blanket Implementations</a></h3><ul class="block"><li><a href="#impl-Any-for-Constant%3CT%2C%20M%3E">Any</a></li><li><a href="#impl-Borrow%3CT%3E-for-Constant%3CT%2C%20M%3E">Borrow&lt;T&gt;</a></li><li><a href="#impl-BorrowMut%3CT%3E-for-Constant%3CT%2C%20M%3E">BorrowMut&lt;T&gt;</a></li><li><a href="#impl-Discover-for-Constant%3CT%2C%20M%3E">Discover</a></li><li><a href="#impl-From%3CT%3E-for-Constant%3CT%2C%20M%3E">From&lt;T&gt;</a></li><li><a href="#impl-Instrument-for-Constant%3CT%2C%20M%3E">Instrument</a></li><li><a href="#impl-Into%3CU%3E-for-Constant%3CT%2C%20M%3E">Into&lt;U&gt;</a></li><li><a href="#impl-ServiceExt%3CRequest%3E-for-Constant%3CT%2C%20M%3E">ServiceExt&lt;Request&gt;</a></li><li><a href="#impl-StreamExt-for-Constant%3CT%2C%20M%3E">StreamExt</a></li><li><a href="#impl-TryFrom%3CU%3E-for-Constant%3CT%2C%20M%3E">TryFrom&lt;U&gt;</a></li><li><a href="#impl-TryInto%3CU%3E-for-Constant%3CT%2C%20M%3E">TryInto&lt;U&gt;</a></li><li><a href="#impl-TryStream-for-Constant%3CT%2C%20M%3E">TryStream</a></li><li><a href="#impl-TryStreamExt-for-Constant%3CT%2C%20M%3E">TryStreamExt</a></li><li><a href="#impl-VZip%3CV%3E-for-Constant%3CT%2C%20M%3E">VZip&lt;V&gt;</a></li><li><a href="#impl-WithSubscriber-for-Constant%3CT%2C%20M%3E">WithSubscriber</a></li></ul></section><h2><a href="index.html">In tower::load</a></h2></div></nav><main><div class="width-limiter"><nav class="sub"><form class="search-form"><div class="search-container"><span></span><input class="search-input" name="search" autocomplete="off" spellcheck="false" placeholder="Click or press ‘S’ to search, ‘?’ for more options…" type="search"><div id="help-button" title="help" tabindex="-1"><a href="../../help.html">?</a></div><div id="settings-menu" tabindex="-1"><a href="../../settings.html" title="settings"><img width="22" height="22" alt="Change settings" src="../../wheel.svg"></a></div></div></form></nav><section id="main-content" class="content"><div class="main-heading"><h1 class="fqn">Struct <a href="../index.html">tower</a>::<wbr><a href="index.html">load</a>::<wbr><a class="struct" href="#">Constant</a><button id="copy-path" onclick="copy_path(this)" title="Copy item path to clipboard"><img src="../../clipboard.svg" width="19" height="18" alt="Copy item path"></button></h1><span class="out-of-band"><a class="srclink" href="../../src/tower/load/constant.rs.html#15-24">source</a> · <a id="toggle-all-docs" href="javascript:void(0)" title="collapse all docs">[<span class="inner">&#x2212;</span>]</a></span></div><div class="item-decl"><pre class="rust struct"><code>pub struct Constant&lt;T, M&gt; { /* private fields */ }</code></pre></div><details class="rustdoc-toggle top-doc" open><summary class="hideme"><span>Expand description</span></summary><div class="docblock"><p>Wraps a type so that it implements <a href="trait.Load.html" title="Load"><code>Load</code></a> and returns a constant load metric.</p>
<p>This load estimator is primarily useful for testing.</p>
</div></details><h2 id="implementations" class="small-section-header">Implementations<a href="#implementations" class="anchor"></a></h2><div id="implementations-list"><details class="rustdoc-toggle implementors-toggle" open><summary><section id="impl-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#28-33">source</a><a href="#impl-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, M:&nbsp;<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Copy.html" title="trait core::marker::Copy">Copy</a>&gt; <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;</h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.new" class="method has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#30-32">source</a><h4 class="code-header">pub fn <a href="#method.new" class="fnname">new</a>(inner: T, load: M) -&gt; Self</h4></section></summary><div class="docblock"><p>Wraps a <code>T</code>-typed service with a constant <code>M</code>-typed load metric.</p>
</div></details></div></details></div><h2 id="trait-implementations" class="small-section-header">Trait Implementations<a href="#trait-implementations" class="anchor"></a></h2><div id="trait-implementations-list"><details class="rustdoc-toggle implementors-toggle" open><summary><section id="impl-Debug-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#16">source</a><a href="#impl-Debug-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T:&nbsp;<a class="trait" href="https://doc.rust-lang.org/nightly/core/fmt/trait.Debug.html" title="trait core::fmt::Debug">Debug</a>, M:&nbsp;<a class="trait" href="https://doc.rust-lang.org/nightly/core/fmt/trait.Debug.html" title="trait core::fmt::Debug">Debug</a>&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/fmt/trait.Debug.html" title="trait core::fmt::Debug">Debug</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;</h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.fmt" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#16">source</a><a href="#method.fmt" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/fmt/trait.Debug.html#tymethod.fmt" class="fnname">fmt</a>(&amp;self, f: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/fmt/struct.Formatter.html" title="struct core::fmt::Formatter">Formatter</a>&lt;'_&gt;) -&gt; <a class="type" href="https://doc.rust-lang.org/nightly/core/fmt/type.Result.html" title="type core::fmt::Result">Result</a></h4></section></summary><div class='docblock'>Formats the value using the given formatter. <a href="https://doc.rust-lang.org/nightly/core/fmt/trait.Debug.html#tymethod.fmt">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle" open><summary><section id="impl-Load-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#35-41">source</a><a href="#impl-Load-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, M:&nbsp;<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Copy.html" title="trait core::marker::Copy">Copy</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/cmp/trait.PartialOrd.html" title="trait core::cmp::PartialOrd">PartialOrd</a>&gt; <a class="trait" href="trait.Load.html" title="trait tower::load::Load">Load</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;</h3></section></summary><div class="impl-items"><details class="rustdoc-toggle" open><summary><section id="associatedtype.Metric" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Metric" class="anchor"></a><h4 class="code-header">type <a href="trait.Load.html#associatedtype.Metric" class="associatedtype">Metric</a> = M</h4></section></summary><div class='docblock'>A comparable load metric. <a href="trait.Load.html#associatedtype.Metric">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.load" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#38-40">source</a><a href="#method.load" class="anchor"></a><h4 class="code-header">fn <a href="trait.Load.html#tymethod.load" class="fnname">load</a>(&amp;self) -&gt; M</h4></section></summary><div class='docblock'>Estimate the service’s current load.</div></details></div></details><details class="rustdoc-toggle implementors-toggle" open><summary><section id="impl-Service%3CRequest%3E-for-Constant%3CS%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#43-59">source</a><a href="#impl-Service%3CRequest%3E-for-Constant%3CS%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;S, M, Request&gt; <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt; for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;S, M&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;S: <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;M: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Copy.html" title="trait core::marker::Copy">Copy</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle" open><summary><section id="associatedtype.Response" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Response" class="anchor"></a><h4 class="code-header">type <a href="../trait.Service.html#associatedtype.Response" class="associatedtype">Response</a> = &lt;S as <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt;&gt;::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a></h4></section></summary><div class='docblock'>Responses given by the service.</div></details><details class="rustdoc-toggle" open><summary><section id="associatedtype.Error" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Error" class="anchor"></a><h4 class="code-header">type <a href="../trait.Service.html#associatedtype.Error" class="associatedtype">Error</a> = &lt;S as <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt;&gt;::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a></h4></section></summary><div class='docblock'>Errors produced by the service.</div></details><details class="rustdoc-toggle" open><summary><section id="associatedtype.Future" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Future" class="anchor"></a><h4 class="code-header">type <a href="../trait.Service.html#associatedtype.Future" class="associatedtype">Future</a> = &lt;S as <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt;&gt;::<a class="associatedtype" href="../trait.Service.html#associatedtype.Future" title="type tower::Service::Future">Future</a></h4></section></summary><div class='docblock'>The future response value.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.poll_ready" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#52-54">source</a><a href="#method.poll_ready" class="anchor"></a><h4 class="code-header">fn <a href="../trait.Service.html#tymethod.poll_ready" class="fnname">poll_ready</a>(&amp;mut self, cx: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/task/wake/struct.Context.html" title="struct core::task::wake::Context">Context</a>&lt;'_&gt;) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/task/poll/enum.Poll.html" title="enum core::task::poll::Poll">Poll</a>&lt;<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="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.unit.html">()</a>, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;&gt;</h4></section></summary><div class='docblock'>Returns <code>Poll::Ready(Ok(()))</code> when the service is able to process requests. <a href="../trait.Service.html#tymethod.poll_ready">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.call" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#56-58">source</a><a href="#method.call" class="anchor"></a><h4 class="code-header">fn <a href="../trait.Service.html#tymethod.call" class="fnname">call</a>(&amp;mut self, req: Request) -&gt; Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Future" title="type tower::Service::Future">Future</a></h4></section></summary><div class='docblock'>Process the request and return the response asynchronously. <a href="../trait.Service.html#tymethod.call">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle" open><summary><section id="impl-Stream-for-Constant%3CD%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#64-80">source</a><a href="#impl-Stream-for-Constant%3CD%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;D:&nbsp;<a class="trait" href="../discover/trait.Discover.html" title="trait tower::discover::Discover">Discover</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>, M:&nbsp;<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Copy.html" title="trait core::marker::Copy">Copy</a>&gt; <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;D, M&gt;</h3></section></summary><div class="docblock"><p>Proxies <a href="../discover/trait.Discover.html" title="Discover"><code>Discover</code></a> such that all changes are wrapped with a constant load.</p>
</div><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.poll_next" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#68-79">source</a><a href="#method.poll_next" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_core/stream/trait.Stream.html#tymethod.poll_next" class="fnname">poll_next</a>(<br>&nbsp;&nbsp;&nbsp;&nbsp;self: <a class="struct" href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html" title="struct core::pin::Pin">Pin</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;mut </a>Self&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;cx: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/task/wake/struct.Context.html" title="struct core::task::wake::Context">Context</a>&lt;'_&gt;<br>) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/task/poll/enum.Poll.html" title="enum core::task::poll::Poll">Poll</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt;&gt;</h4></section></summary><div class="docblock"><p>Yields the next discovery change set.</p>
</div></details><details class="rustdoc-toggle" open><summary><section id="associatedtype.Item" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Item" class="anchor"></a><h4 class="code-header">type <a href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" class="associatedtype">Item</a> = <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="enum" href="../discover/enum.Change.html" title="enum tower::discover::Change">Change</a>&lt;&lt;D as <a class="trait" href="../discover/trait.Discover.html" title="trait tower::discover::Discover">Discover</a>&gt;::<a class="associatedtype" href="../discover/trait.Discover.html#associatedtype.Key" title="type tower::discover::Discover::Key">Key</a>, <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;&lt;D as <a class="trait" href="../discover/trait.Discover.html" title="trait tower::discover::Discover">Discover</a>&gt;::<a class="associatedtype" href="../discover/trait.Discover.html#associatedtype.Service" title="type tower::discover::Discover::Service">Service</a>, M&gt;&gt;, &lt;D as <a class="trait" href="../discover/trait.Discover.html" title="trait tower::discover::Discover">Discover</a>&gt;::<a class="associatedtype" href="../discover/trait.Discover.html#associatedtype.Error" title="type tower::discover::Discover::Error">Error</a>&gt;</h4></section></summary><div class='docblock'>Values yielded by the stream.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.size_hint" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_core/stream.rs.html#95">source</a><a href="#method.size_hint" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_core/stream/trait.Stream.html#method.size_hint" class="fnname">size_hint</a>(&amp;self) -&gt; (<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>, <a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>&gt;)</h4></section></summary><div class='docblock'>Returns the bounds on the remaining length of the stream. <a href="../../futures_core/stream/trait.Stream.html#method.size_hint">Read more</a></div></details></div></details><section id="impl-Unpin-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/load/constant.rs.html#15-24">source</a><a href="#impl-Unpin-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;'__pin, T, M&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;__Origin&lt;'__pin, T, M&gt;: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h3></section></div><h2 id="synthetic-implementations" class="small-section-header">Auto Trait Implementations<a href="#synthetic-implementations" class="anchor"></a></h2><div id="synthetic-implementations-list"><section id="impl-RefUnwindSafe-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a href="#impl-RefUnwindSafe-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, M&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/panic/unwind_safe/trait.RefUnwindSafe.html" title="trait core::panic::unwind_safe::RefUnwindSafe">RefUnwindSafe</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;M: <a class="trait" href="https://doc.rust-lang.org/nightly/core/panic/unwind_safe/trait.RefUnwindSafe.html" title="trait core::panic::unwind_safe::RefUnwindSafe">RefUnwindSafe</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="https://doc.rust-lang.org/nightly/core/panic/unwind_safe/trait.RefUnwindSafe.html" title="trait core::panic::unwind_safe::RefUnwindSafe">RefUnwindSafe</a>,</span></h3></section><section id="impl-Send-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a href="#impl-Send-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, M&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;M: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a>,</span></h3></section><section id="impl-Sync-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a href="#impl-Sync-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, M&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sync.html" title="trait core::marker::Sync">Sync</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;M: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sync.html" title="trait core::marker::Sync">Sync</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sync.html" title="trait core::marker::Sync">Sync</a>,</span></h3></section><section id="impl-UnwindSafe-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a href="#impl-UnwindSafe-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, M&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/panic/unwind_safe/trait.UnwindSafe.html" title="trait core::panic::unwind_safe::UnwindSafe">UnwindSafe</a> for <a class="struct" href="struct.Constant.html" title="struct tower::load::Constant">Constant</a>&lt;T, M&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;M: <a class="trait" href="https://doc.rust-lang.org/nightly/core/panic/unwind_safe/trait.UnwindSafe.html" title="trait core::panic::unwind_safe::UnwindSafe">UnwindSafe</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="https://doc.rust-lang.org/nightly/core/panic/unwind_safe/trait.UnwindSafe.html" title="trait core::panic::unwind_safe::UnwindSafe">UnwindSafe</a>,</span></h3></section></div><h2 id="blanket-implementations" class="small-section-header">Blanket Implementations<a href="#blanket-implementations" class="anchor"></a></h2><div id="blanket-implementations-list"><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-Any-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/any.rs.html#200">source</a><a href="#impl-Any-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/any/trait.Any.html" title="trait core::any::Any">Any</a> for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: 'static + ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.type_id" class="method trait-impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/any.rs.html#201">source</a><a href="#method.type_id" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/any/trait.Any.html#tymethod.type_id" class="fnname">type_id</a>(&amp;self) -&gt; <a class="struct" href="https://doc.rust-lang.org/nightly/core/any/struct.TypeId.html" title="struct core::any::TypeId">TypeId</a></h4></section></summary><div class='docblock'>Gets the <code>TypeId</code> of <code>self</code>. <a href="https://doc.rust-lang.org/nightly/core/any/trait.Any.html#tymethod.type_id">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-Borrow%3CT%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/borrow.rs.html#211">source</a><a href="#impl-Borrow%3CT%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/borrow/trait.Borrow.html" title="trait core::borrow::Borrow">Borrow</a>&lt;T&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.borrow" class="method trait-impl has-srclink"><span class="rightside"><span class="since" title="const unstable">const: <a href="https://github.com/rust-lang/rust/issues/91522" title="Tracking issue for const_borrow">unstable</a></span> · <a class="srclink" href="https://doc.rust-lang.org/nightly/src/core/borrow.rs.html#213">source</a></span><a href="#method.borrow" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/borrow/trait.Borrow.html#tymethod.borrow" class="fnname">borrow</a>(&amp;self) -&gt; <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;</a>T</h4></section></summary><div class='docblock'>Immutably borrows from an owned value. <a href="https://doc.rust-lang.org/nightly/core/borrow/trait.Borrow.html#tymethod.borrow">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-BorrowMut%3CT%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/borrow.rs.html#220">source</a><a href="#impl-BorrowMut%3CT%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/borrow/trait.BorrowMut.html" title="trait core::borrow::BorrowMut">BorrowMut</a>&lt;T&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.borrow_mut" class="method trait-impl has-srclink"><span class="rightside"><span class="since" title="const unstable">const: <a href="https://github.com/rust-lang/rust/issues/91522" title="Tracking issue for const_borrow">unstable</a></span> · <a class="srclink" href="https://doc.rust-lang.org/nightly/src/core/borrow.rs.html#221">source</a></span><a href="#method.borrow_mut" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/borrow/trait.BorrowMut.html#tymethod.borrow_mut" class="fnname">borrow_mut</a>(&amp;mut self) -&gt; <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;mut </a>T</h4></section></summary><div class='docblock'>Mutably borrows from an owned value. <a href="https://doc.rust-lang.org/nightly/core/borrow/trait.BorrowMut.html#tymethod.borrow_mut">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-Discover-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/discover/mod.rs.html#83-98">source</a><a href="#impl-Discover-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;K, S, E, D&gt; <a class="trait" href="../discover/trait.Discover.html" title="trait tower::discover::Discover">Discover</a> for D<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;D: <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&lt;Ok = <a class="enum" href="../discover/enum.Change.html" title="enum tower::discover::Change">Change</a>&lt;K, S&gt;, Error = E&gt; + ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;K: <a class="trait" href="https://doc.rust-lang.org/nightly/core/cmp/trait.Eq.html" title="trait core::cmp::Eq">Eq</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle" open><summary><section id="associatedtype.Key" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Key" class="anchor"></a><h4 class="code-header">type <a href="../discover/trait.Discover.html#associatedtype.Key" class="associatedtype">Key</a> = K</h4></section></summary><div class='docblock'>A unique identifier for each active service. <a href="../discover/trait.Discover.html#associatedtype.Key">Read more</a></div></details><details class="rustdoc-toggle" open><summary><section id="associatedtype.Service" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Service" class="anchor"></a><h4 class="code-header">type <a href="../discover/trait.Discover.html#associatedtype.Service" class="associatedtype">Service</a> = S</h4></section></summary><div class='docblock'>The type of <a href="../trait.Service.html"><code>Service</code></a> yielded by this <a href="../discover/trait.Discover.html" title="Discover"><code>Discover</code></a>. <a href="../discover/trait.Discover.html#associatedtype.Service">Read more</a></div></details><details class="rustdoc-toggle" open><summary><section id="associatedtype.Error-1" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Error-1" class="anchor"></a><h4 class="code-header">type <a href="../discover/trait.Discover.html#associatedtype.Error" class="associatedtype">Error</a> = E</h4></section></summary><div class='docblock'>Error produced during discovery</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.poll_discover" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/discover/mod.rs.html#92-97">source</a><a href="#method.poll_discover" class="anchor"></a><h4 class="code-header">fn <a href="../discover/trait.Discover.html#tymethod.poll_discover" class="fnname">poll_discover</a>(<br>&nbsp;&nbsp;&nbsp;&nbsp;self: <a class="struct" href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html" title="struct core::pin::Pin">Pin</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;mut </a>D&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;cx: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/task/wake/struct.Context.html" title="struct core::task::wake::Context">Context</a>&lt;'_&gt;<br>) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/task/poll/enum.Poll.html" title="enum core::task::poll::Poll">Poll</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;&lt;D as <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&gt;::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>, &lt;D as <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&gt;::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;&gt;&gt;</h4></section></summary><div class='docblock'>Yields the next discovery change set.</div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-From%3CT%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#733">source</a><a href="#impl-From%3CT%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;T&gt; for T</h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.from" class="method trait-impl has-srclink"><span class="rightside"><span class="since" title="const unstable">const: <a href="https://github.com/rust-lang/rust/issues/88674" title="Tracking issue for const_convert">unstable</a></span> · <a class="srclink" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#736">source</a></span><a href="#method.from" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html#tymethod.from" class="fnname">from</a>(t: T) -&gt; T</h4></section></summary><div class="docblock"><p>Returns the argument unchanged.</p>
</div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-Instrument-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tracing/instrument.rs.html#276">source</a><a href="#impl-Instrument-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="../../tracing/instrument/trait.Instrument.html" title="trait tracing::instrument::Instrument">Instrument</a> for T</h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.instrument" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tracing/instrument.rs.html#82">source</a><a href="#method.instrument" class="anchor"></a><h4 class="code-header">fn <a href="../../tracing/instrument/trait.Instrument.html#method.instrument" class="fnname">instrument</a>(self, span: <a class="struct" href="../../tracing/span/struct.Span.html" title="struct tracing::span::Span">Span</a>) -&gt; <a class="struct" href="../../tracing/instrument/struct.Instrumented.html" title="struct tracing::instrument::Instrumented">Instrumented</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Instruments this type with the provided <a href="../../tracing/span/struct.Span.html" title="Span"><code>Span</code></a>, returning an
<code>Instrumented</code> wrapper. <a href="../../tracing/instrument/trait.Instrument.html#method.instrument">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.in_current_span" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tracing/instrument.rs.html#121">source</a><a href="#method.in_current_span" class="anchor"></a><h4 class="code-header">fn <a href="../../tracing/instrument/trait.Instrument.html#method.in_current_span" class="fnname">in_current_span</a>(self) -&gt; <a class="struct" href="../../tracing/instrument/struct.Instrumented.html" title="struct tracing::instrument::Instrumented">Instrumented</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Instruments this type with the <a href="../../tracing/span/struct.Span.html#method.current">current</a> <a href="../../tracing/span/struct.Span.html"><code>Span</code></a>, returning an
<code>Instrumented</code> wrapper. <a href="../../tracing/instrument/trait.Instrument.html#method.in_current_span">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-Into%3CU%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#717">source</a><a href="#impl-Into%3CU%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, U&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;U&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;U: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;T&gt;,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.into" class="method trait-impl has-srclink"><span class="rightside"><span class="since" title="const unstable">const: <a href="https://github.com/rust-lang/rust/issues/88674" title="Tracking issue for const_convert">unstable</a></span> · <a class="srclink" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#725">source</a></span><a href="#method.into" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html#tymethod.into" class="fnname">into</a>(self) -&gt; U</h4></section></summary><div class="docblock"><p>Calls <code>U::from(self)</code>.</p>
<p>That is, this conversion is whatever the implementation of
<code><a href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="From">From</a>&lt;T&gt; for U</code> chooses to do.</p>
</div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-ServiceExt%3CRequest%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#1055">source</a><a href="#impl-ServiceExt%3CRequest%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, Request&gt; <a class="trait" href="../trait.ServiceExt.html" title="trait tower::ServiceExt">ServiceExt</a>&lt;Request&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt; + ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.ready" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#67-72">source</a><a href="#method.ready" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.ready" class="fnname">ready</a>(&amp;mut self) -&gt; <a class="struct" href="../util/struct.Ready.html" title="struct tower::util::Ready">Ready</a>&lt;'_, Self, Request&gt;<span class="notable-traits"><span class="notable-traits-tooltip"><span class="notable-traits-tooltiptext"><span class="docblock"><span class="notable">Notable traits for <a class="struct" href="../util/struct.Ready.html" title="struct tower::util::Ready">Ready</a>&lt;'a, T, Request&gt;</span><code class="content"><span class="where fmt-newline">impl&lt;'a, T, Request&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a> for <a class="struct" href="../util/struct.Ready.html" title="struct tower::util::Ready">Ready</a>&lt;'a, T, Request&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt;,</span></span><span class="where fmt-newline"> type <a href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html#associatedtype.Output" class="associatedtype">Output</a> = <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="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;'a mut </a>T, T::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;;</span></code></span></span></span></span><span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h4></section></summary><div class='docblock'>Yields a mutable reference to the service when it is ready to accept a request.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.ready_and" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#80-85">source</a><a href="#method.ready_and" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.ready_and" class="fnname">ready_and</a>(&amp;mut self) -&gt; <a class="type" href="../util/type.ReadyAnd.html" title="type tower::util::ReadyAnd">ReadyAnd</a>&lt;'_, Self, Request&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h4></section></summary><span class="item-info"><div class="stab deprecated"><span class="emoji">👎</span><span>Deprecated since 0.4.6: please use the <code>ServiceExt::ready</code> method instead</span></div></span><div class='docblock'>Yields a mutable reference to the service when it is ready to accept a request.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.ready_oneshot" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#88-93">source</a><a href="#method.ready_oneshot" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.ready_oneshot" class="fnname">ready_oneshot</a>(self) -&gt; <a class="struct" href="../util/struct.ReadyOneshot.html" title="struct tower::util::ReadyOneshot">ReadyOneshot</a>&lt;Self, Request&gt;<span class="notable-traits"><span class="notable-traits-tooltip"><span class="notable-traits-tooltiptext"><span class="docblock"><span class="notable">Notable traits for <a class="struct" href="../util/struct.ReadyOneshot.html" title="struct tower::util::ReadyOneshot">ReadyOneshot</a>&lt;T, Request&gt;</span><code class="content"><span class="where fmt-newline">impl&lt;T, Request&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a> for <a class="struct" href="../util/struct.ReadyOneshot.html" title="struct tower::util::ReadyOneshot">ReadyOneshot</a>&lt;T, Request&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Request&gt;,</span></span><span class="where fmt-newline"> type <a href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html#associatedtype.Output" class="associatedtype">Output</a> = <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;T, T::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;;</span></code></span></span></span></span><span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h4></section></summary><div class='docblock'>Yields the service when it is ready to accept a request.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.oneshot" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#96-101">source</a><a href="#method.oneshot" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.oneshot" class="fnname">oneshot</a>(self, req: Request) -&gt; <a class="struct" href="../util/struct.Oneshot.html" title="struct tower::util::Oneshot">Oneshot</a>&lt;Self, Request&gt;<span class="notable-traits"><span class="notable-traits-tooltip"><span class="notable-traits-tooltiptext"><span class="docblock"><span class="notable">Notable traits for <a class="struct" href="../util/struct.Oneshot.html" title="struct tower::util::Oneshot">Oneshot</a>&lt;S, Req&gt;</span><code class="content"><span class="where fmt-newline">impl&lt;S, Req&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a> for <a class="struct" href="../util/struct.Oneshot.html" title="struct tower::util::Oneshot">Oneshot</a>&lt;S, Req&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;S: <a class="trait" href="../trait.Service.html" title="trait tower::Service">Service</a>&lt;Req&gt;,</span></span><span class="where fmt-newline"> type <a href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html#associatedtype.Output" class="associatedtype">Output</a> = <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;S::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a>, S::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;;</span></code></span></span></span></span><span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h4></section></summary><div class='docblock'>Consume this <code>Service</code>, calling with the providing request once it is ready.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.call_all" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#111-118">source</a><a href="#method.call_all" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.call_all" class="fnname">call_all</a>&lt;S&gt;(self, reqs: S) -&gt; <a class="struct" href="../util/struct.CallAll.html" title="struct tower::util::CallAll">CallAll</a>&lt;Self, S&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="type" href="../type.BoxError.html" title="type tower::BoxError">BoxError</a>&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;S: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = Request&gt;,</span></h4></section></summary><div class='docblock'>Process all requests from the given <a href="https://docs.rs/futures/latest/futures/stream/trait.Stream.html"><code>Stream</code></a>, and produce a <a href="https://docs.rs/futures/latest/futures/stream/trait.Stream.html"><code>Stream</code></a> of their responses. <a href="../trait.ServiceExt.html#method.call_all">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.and_then" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#180-186">source</a><a href="#method.and_then" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.and_then" class="fnname">and_then</a>&lt;F&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.AndThen.html" title="struct tower::util::AndThen">AndThen</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a>,</span></h4></section></summary><div class='docblock'>Executes a new future after this service’s future resolves. This does
not alter the behaviour of the <a href="../trait.Service.html#tymethod.poll_ready"><code>poll_ready</code></a> method. <a href="../trait.ServiceExt.html#method.and_then">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_response" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#249-255">source</a><a href="#method.map_response" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.map_response" class="fnname">map_response</a>&lt;F, Response&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.MapResponse.html" title="struct tower::util::MapResponse">MapResponse</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;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>(Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a>) -&gt; Response + <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a>,</span></h4></section></summary><div class='docblock'>Maps this service’s response value to a different value. This does not
alter the behaviour of the <a href="../trait.Service.html#tymethod.poll_ready"><code>poll_ready</code></a> method. <a href="../trait.ServiceExt.html#method.map_response">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_err" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#317-323">source</a><a href="#method.map_err" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.map_err" class="fnname">map_err</a>&lt;F, Error&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.MapErr.html" title="struct tower::util::MapErr">MapErr</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;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>(Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>) -&gt; Error + <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a>,</span></h4></section></summary><div class='docblock'>Maps this service’s error value to a different value. This does not
alter the behaviour of the <a href="../trait.Service.html#tymethod.poll_ready"><code>poll_ready</code></a> method. <a href="../trait.ServiceExt.html#method.map_err">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_result" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#546-553">source</a><a href="#method.map_result" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.map_result" class="fnname">map_result</a>&lt;F, Response, Error&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.MapResult.html" title="struct tower::util::MapResult">MapResult</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;Error: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;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="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a>, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;Response, Error&gt; + <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a>,</span></h4></section></summary><div class='docblock'>Maps this service’s result type (<code>Result&lt;Self::Response, Self::Error&gt;</code>)
to a different value, regardless of whether the future succeeds or
fails. <a href="../trait.ServiceExt.html#method.map_result">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_request" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#606-612">source</a><a href="#method.map_request" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.map_request" class="fnname">map_request</a>&lt;F, NewRequest&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.MapRequest.html" title="struct tower::util::MapRequest">MapRequest</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(NewRequest) -&gt; Request,</span></h4></section></summary><div class='docblock'>Composes a function <em>in front of</em> the service. <a href="../trait.ServiceExt.html#method.map_request">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.then" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#873-881">source</a><a href="#method.then" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.then" class="fnname">then</a>&lt;F, Response, Error, Fut&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.Then.html" title="struct tower::util::Then">Then</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;Error: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;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="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a>, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;) -&gt; Fut + <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;Response, Error&gt;&gt;,</span></h4></section></summary><div class='docblock'>Composes an asynchronous function <em>after</em> this service. <a href="../trait.ServiceExt.html#method.then">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_future" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#947-955">source</a><a href="#method.map_future" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.map_future" class="fnname">map_future</a>&lt;F, Fut, Response, Error&gt;(self, f: F) -&gt; <a class="struct" href="../util/struct.MapFuture.html" title="struct tower::util::MapFuture">MapFuture</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Future" title="type tower::Service::Future">Future</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Error: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;Response, Error&gt;&gt;,</span></h4></section></summary><div class='docblock'>Composes a function that transforms futures produced by the service. <a href="../trait.ServiceExt.html#method.map_future">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.boxed" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#997-1003">source</a><a href="#method.boxed" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.boxed" class="fnname">boxed</a>(self) -&gt; <a class="struct" href="../util/struct.BoxService.html" title="struct tower::util::BoxService">BoxService</a>&lt;Request, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a>, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a> + 'static,<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Future" title="type tower::Service::Future">Future</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a> + 'static,</span></h4></section></summary><div class='docblock'>Convert the service into a <a href="../trait.Service.html"><code>Service</code></a> + <a href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="Send"><code>Send</code></a> trait object. <a href="../trait.ServiceExt.html#method.boxed">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.boxed_clone" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tower/util/mod.rs.html#1046-1052">source</a><a href="#method.boxed_clone" class="anchor"></a><h4 class="code-header">fn <a href="../trait.ServiceExt.html#method.boxed_clone" class="fnname">boxed_clone</a>(self) -&gt; <a class="struct" href="../util/struct.BoxCloneService.html" title="struct tower::util::BoxCloneService">BoxCloneService</a>&lt;Request, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Response" title="type tower::Service::Response">Response</a>, Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Error" title="type tower::Service::Error">Error</a>&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a> + 'static,<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../trait.Service.html#associatedtype.Future" title="type tower::Service::Future">Future</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a> + 'static,</span></h4></section></summary><div class='docblock'>Convert the service into a <a href="../trait.Service.html"><code>Service</code></a> + <a href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="Clone"><code>Clone</code></a> + <a href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="Send"><code>Send</code></a> trait object. <a href="../trait.ServiceExt.html#method.boxed_clone">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-StreamExt-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#245">source</a><a href="#impl-StreamExt-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="../../futures_util/stream/stream/trait.StreamExt.html" title="trait futures_util::stream::stream::StreamExt">StreamExt</a> for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;T: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a> + ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.next" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#273-275">source</a><a href="#method.next" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.next" class="fnname">next</a>(&amp;mut self) -&gt; <a class="struct" href="../../futures_util/stream/stream/next/struct.Next.html" title="struct futures_util::stream::stream::next::Next">Next</a>&lt;'_, Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h4></section></summary><div class='docblock'>Creates a future that resolves to the next item in the stream. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.next">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.into_future" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#308-310">source</a><a href="#method.into_future" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.into_future" class="fnname">into_future</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/into_future/struct.StreamFuture.html" title="struct futures_util::stream::stream::into_future::StreamFuture">StreamFuture</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h4></section></summary><div class='docblock'>Converts this stream into a future of <code>(next_item, tail_of_stream)</code>.
If the stream terminates, then the next item is <a href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html#variant.None" title="None"><code>None</code></a>. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.into_future">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#338-341">source</a><a href="#method.map" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.map" class="fnname">map</a>&lt;T, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/map/struct.Map.html" title="struct futures_util::stream::stream::map::Map">Map</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; T,</span></h4></section></summary><div class='docblock'>Maps this stream’s items to a different type, returning a new stream of
the resulting type. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.map">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.enumerate" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#384-386">source</a><a href="#method.enumerate" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.enumerate" class="fnname">enumerate</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/enumerate/struct.Enumerate.html" title="struct futures_util::stream::stream::enumerate::Enumerate">Enumerate</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Creates a stream which gives the current iteration count as well as
the next value. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.enumerate">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.filter" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#417-421">source</a><a href="#method.filter" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.filter" class="fnname">filter</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/filter/struct.Filter.html" title="struct futures_util::stream::stream::filter::Filter">Filter</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>&gt;,</span></h4></section></summary><div class='docblock'>Filters the values produced by this stream according to the provided
asynchronous predicate. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.filter">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.filter_map" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#451-455">source</a><a href="#method.filter_map" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.filter_map" class="fnname">filter_map</a>&lt;Fut, T, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/filter_map/struct.FilterMap.html" title="struct futures_util::stream::stream::filter_map::FilterMap">FilterMap</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;T&gt;&gt;,</span></h4></section></summary><div class='docblock'>Filters the values produced by this stream while simultaneously mapping
them to a different type according to the provided asynchronous closure. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.filter_map">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.then-1" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#482-486">source</a><a href="#method.then-1" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.then" class="fnname">then</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/then/struct.Then.html" title="struct futures_util::stream::stream::then::Then">Then</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>,</span></h4></section></summary><div class='docblock'>Computes from this stream’s items new items of a different type using
an asynchronous closure. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.then">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.collect" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#516-518">source</a><a href="#method.collect" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.collect" class="fnname">collect</a>&lt;C&gt;(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/collect/struct.Collect.html" title="struct futures_util::stream::stream::collect::Collect">Collect</a>&lt;Self, C&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;C: <a class="trait" href="https://doc.rust-lang.org/nightly/core/default/trait.Default.html" title="trait core::default::Default">Default</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.Extend.html" title="trait core::iter::traits::collect::Extend">Extend</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt;,</span></h4></section></summary><div class='docblock'>Transforms a stream into a collection, returning a
future representing the result of that computation. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.collect">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.unzip" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#553-557">source</a><a href="#method.unzip" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.unzip" class="fnname">unzip</a>&lt;A, B, FromA, FromB&gt;(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/unzip/struct.Unzip.html" title="struct futures_util::stream::stream::unzip::Unzip">Unzip</a>&lt;Self, FromA, FromB&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;FromA: <a class="trait" href="https://doc.rust-lang.org/nightly/core/default/trait.Default.html" title="trait core::default::Default">Default</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.Extend.html" title="trait core::iter::traits::collect::Extend">Extend</a>&lt;A&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;FromB: <a class="trait" href="https://doc.rust-lang.org/nightly/core/default/trait.Default.html" title="trait core::default::Default">Default</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.Extend.html" title="trait core::iter::traits::collect::Extend">Extend</a>&lt;B&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.tuple.html">(A, B)</a>&gt;,</span></h4></section></summary><div class='docblock'>Converts a stream of pairs into a future, which
resolves to pair of containers. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.unzip">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.concat" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#594-597">source</a><a href="#method.concat" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.concat" class="fnname">concat</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/concat/struct.Concat.html" title="struct futures_util::stream::stream::concat::Concat">Concat</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.Extend.html" title="trait core::iter::traits::collect::Extend">Extend</a>&lt;&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a> as <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.IntoIterator.html" title="trait core::iter::traits::collect::IntoIterator">IntoIterator</a>&gt;::<a class="associatedtype" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.IntoIterator.html#associatedtype.Item" title="type core::iter::traits::collect::IntoIterator::Item">Item</a>&gt; + <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.IntoIterator.html" title="trait core::iter::traits::collect::IntoIterator">IntoIterator</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/default/trait.Default.html" title="trait core::default::Default">Default</a>,</span></h4></section></summary><div class='docblock'>Concatenate all items of a stream into a single extendable
destination, returning a future representing the end result. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.concat">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.count" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#627-629">source</a><a href="#method.count" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.count" class="fnname">count</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/count/struct.Count.html" title="struct futures_util::stream::stream::count::Count">Count</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Drives the stream to completion, counting the number of items. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.count">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.cycle" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#657-659">source</a><a href="#method.cycle" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.cycle" class="fnname">cycle</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/cycle/struct.Cycle.html" title="struct futures_util::stream::stream::cycle::Cycle">Cycle</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/clone/trait.Clone.html" title="trait core::clone::Clone">Clone</a>,</span></h4></section></summary><div class='docblock'>Repeats a stream endlessly. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.cycle">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.fold" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#684-688">source</a><a href="#method.fold" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.fold" class="fnname">fold</a>&lt;T, Fut, F&gt;(self, init: T, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/fold/struct.Fold.html" title="struct futures_util::stream::stream::fold::Fold">Fold</a>&lt;Self, Fut, T, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(T, Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = T&gt;,</span></h4></section></summary><div class='docblock'>Execute an accumulating asynchronous computation over a stream,
collecting all the values into one final result. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.fold">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.any" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#706-710">source</a><a href="#method.any" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.any" class="fnname">any</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/any/struct.Any.html" title="struct futures_util::stream::stream::any::Any">Any</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>&gt;,</span></h4></section></summary><div class='docblock'>Execute predicate over asynchronous stream, and return <code>true</code> if any element in stream satisfied a predicate. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.any">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.all" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#728-732">source</a><a href="#method.all" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.all" class="fnname">all</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/all/struct.All.html" title="struct futures_util::stream::stream::all::All">All</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>&gt;,</span></h4></section></summary><div class='docblock'>Execute predicate over asynchronous stream, and return <code>true</code> if all element in stream satisfied a predicate. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.all">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.flatten" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#768-771">source</a><a href="#method.flatten" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flatten" class="fnname">flatten</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/struct.Flatten.html" title="struct futures_util::stream::stream::Flatten">Flatten</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>,</span></h4></section></summary><div class='docblock'>Flattens a stream of streams into just one continuous stream. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flatten">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.flatten_unordered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#819-822">source</a><a href="#method.flatten_unordered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flatten_unordered" class="fnname">flatten_unordered</a>(<br>&nbsp;&nbsp;&nbsp;&nbsp;self,<br>&nbsp;&nbsp;&nbsp;&nbsp;limit: impl <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>&gt;&gt;<br>) -&gt; FlattenUnorderedWithFlowController&lt;Self, <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.unit.html">()</a>&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h4></section></summary><div class='docblock'>Flattens a stream of streams into just one continuous stream. Polls
inner streams produced by the base stream concurrently. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flatten_unordered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.flat_map" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#852-856">source</a><a href="#method.flat_map" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flat_map" class="fnname">flat_map</a>&lt;U, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/struct.FlatMap.html" title="struct futures_util::stream::stream::FlatMap">FlatMap</a>&lt;Self, U, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; U,<br>&nbsp;&nbsp;&nbsp;&nbsp;U: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>,</span></h4></section></summary><div class='docblock'>Maps a stream like <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.map" title="StreamExt::map"><code>StreamExt::map</code></a> but flattens nested <code>Stream</code>s. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flat_map">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.flat_map_unordered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#901-909">source</a><a href="#method.flat_map_unordered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flat_map_unordered" class="fnname">flat_map_unordered</a>&lt;U, F&gt;(<br>&nbsp;&nbsp;&nbsp;&nbsp;self,<br>&nbsp;&nbsp;&nbsp;&nbsp;limit: impl <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>&gt;&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;f: F<br>) -&gt; <a class="struct" href="../../futures_util/stream/stream/struct.FlatMapUnordered.html" title="struct futures_util::stream::stream::FlatMapUnordered">FlatMapUnordered</a>&lt;Self, U, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;U: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; U,</span></h4></section></summary><div class='docblock'>Maps a stream like <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.map" title="StreamExt::map"><code>StreamExt::map</code></a> but flattens nested <code>Stream</code>s
and polls them concurrently, yielding items in any order, as they made
available. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.flat_map_unordered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.scan" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#938-942">source</a><a href="#method.scan" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.scan" class="fnname">scan</a>&lt;S, B, Fut, F&gt;(self, initial_state: S, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/scan/struct.Scan.html" title="struct futures_util::stream::stream::scan::Scan">Scan</a>&lt;Self, S, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;mut </a>S, Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;B&gt;&gt;,</span></h4></section></summary><div class='docblock'>Combinator similar to <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.fold" title="StreamExt::fold"><code>StreamExt::fold</code></a> that holds internal state
and produces a new stream. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.scan">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.skip_while" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#969-973">source</a><a href="#method.skip_while" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.skip_while" class="fnname">skip_while</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/skip_while/struct.SkipWhile.html" title="struct futures_util::stream::stream::skip_while::SkipWhile">SkipWhile</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>&gt;,</span></h4></section></summary><div class='docblock'>Skip elements on this stream while the provided asynchronous predicate
resolves to <code>true</code>. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.skip_while">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.take_while" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#999-1003">source</a><a href="#method.take_while" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.take_while" class="fnname">take_while</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/take_while/struct.TakeWhile.html" title="struct futures_util::stream::stream::take_while::TakeWhile">TakeWhile</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>&gt;,</span></h4></section></summary><div class='docblock'>Take elements from this stream while the provided asynchronous predicate
resolves to <code>true</code>. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.take_while">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.take_until" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1044-1047">source</a><a href="#method.take_until" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.take_until" class="fnname">take_until</a>&lt;Fut&gt;(self, fut: Fut) -&gt; <a class="struct" href="../../futures_util/stream/stream/take_until/struct.TakeUntil.html" title="struct futures_util::stream::stream::take_until::TakeUntil">TakeUntil</a>&lt;Self, Fut&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>,</span></h4></section></summary><div class='docblock'>Take elements from this stream until the provided future resolves. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.take_until">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.for_each" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1085-1089">source</a><a href="#method.for_each" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.for_each" class="fnname">for_each</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/for_each/struct.ForEach.html" title="struct futures_util::stream::stream::for_each::ForEach">ForEach</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.unit.html">()</a>&gt;,</span></h4></section></summary><div class='docblock'>Runs this stream to completion, executing the provided asynchronous
closure for each element on the stream. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.for_each">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.for_each_concurrent" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1141-1149">source</a><a href="#method.for_each_concurrent" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.for_each_concurrent" class="fnname">for_each_concurrent</a>&lt;Fut, F&gt;(<br>&nbsp;&nbsp;&nbsp;&nbsp;self,<br>&nbsp;&nbsp;&nbsp;&nbsp;limit: impl <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>&gt;&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;f: F<br>) -&gt; <a class="struct" href="../../futures_util/stream/stream/for_each_concurrent/struct.ForEachConcurrent.html" title="struct futures_util::stream::stream::for_each_concurrent::ForEachConcurrent">ForEachConcurrent</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.unit.html">()</a>&gt;,</span></h4></section></summary><div class='docblock'>Runs this stream to completion, executing the provided asynchronous
closure for each element on the stream concurrently as elements become
available. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.for_each_concurrent">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.take" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1170-1172">source</a><a href="#method.take" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.take" class="fnname">take</a>(self, n: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/stream/take/struct.Take.html" title="struct futures_util::stream::stream::take::Take">Take</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Creates a new stream of at most <code>n</code> items of the underlying stream. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.take">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.skip" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1193-1195">source</a><a href="#method.skip" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.skip" class="fnname">skip</a>(self, n: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/stream/skip/struct.Skip.html" title="struct futures_util::stream::stream::skip::Skip">Skip</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Creates a new stream which skips <code>n</code> items of the underlying stream. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.skip">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.fuse" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1239-1241">source</a><a href="#method.fuse" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.fuse" class="fnname">fuse</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/fuse/struct.Fuse.html" title="struct futures_util::stream::stream::fuse::Fuse">Fuse</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Fuse a stream such that <a href="../../futures_core/stream/trait.Stream.html#tymethod.poll_next"><code>poll_next</code></a> will never
again be called once it has finished. This method can be used to turn
any <code>Stream</code> into a <code>FusedStream</code>. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.fuse">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.by_ref" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1272">source</a><a href="#method.by_ref" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.by_ref" class="fnname">by_ref</a>(&amp;mut self) -&gt; <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;mut </a>Self</h4></section></summary><div class='docblock'>Borrows a stream, rather than consuming it. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.by_ref">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.boxed-1" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1329-1331">source</a><a href="#method.boxed-1" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.boxed" class="fnname">boxed</a>&lt;'a&gt;(<br>&nbsp;&nbsp;&nbsp;&nbsp;self<br>) -&gt; <a class="struct" href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html" title="struct core::pin::Pin">Pin</a>&lt;<a class="struct" href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html" title="struct alloc::boxed::Box">Box</a>&lt;dyn <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt; + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a> + 'a, <a class="struct" href="https://doc.rust-lang.org/nightly/alloc/alloc/struct.Global.html" title="struct alloc::alloc::Global">Global</a>&gt;&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: 'a + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Send.html" title="trait core::marker::Send">Send</a>,</span></h4></section></summary><div class='docblock'>Wrap the stream in a Box, pinning it. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.boxed">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.boxed_local" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1343-1345">source</a><a href="#method.boxed_local" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.boxed_local" class="fnname">boxed_local</a>&lt;'a&gt;(self) -&gt; <a class="struct" href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html" title="struct core::pin::Pin">Pin</a>&lt;<a class="struct" href="https://doc.rust-lang.org/nightly/alloc/boxed/struct.Box.html" title="struct alloc::boxed::Box">Box</a>&lt;dyn <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt; + 'a, <a class="struct" href="https://doc.rust-lang.org/nightly/alloc/alloc/struct.Global.html" title="struct alloc::alloc::Global">Global</a>&gt;&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: 'a,</span></h4></section></summary><div class='docblock'>Wrap the stream in a Box, pinning it. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.boxed_local">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.buffered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1364-1367">source</a><a href="#method.buffered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.buffered" class="fnname">buffered</a>(self, n: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/stream/buffered/struct.Buffered.html" title="struct futures_util::stream::stream::buffered::Buffered">Buffered</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>,</span></h4></section></summary><div class='docblock'>An adaptor for creating a buffered list of pending futures. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.buffered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.buffer_unordered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1409-1412">source</a><a href="#method.buffer_unordered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.buffer_unordered" class="fnname">buffer_unordered</a>(self, n: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/stream/buffer_unordered/struct.BufferUnordered.html" title="struct futures_util::stream::stream::buffer_unordered::BufferUnordered">BufferUnordered</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>,</span></h4></section></summary><div class='docblock'>An adaptor for creating a buffered list of pending futures (unordered). <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.buffer_unordered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.zip" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1439-1442">source</a><a href="#method.zip" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.zip" class="fnname">zip</a>&lt;St&gt;(self, other: St) -&gt; <a class="struct" href="../../futures_util/stream/stream/zip/struct.Zip.html" title="struct futures_util::stream::stream::zip::Zip">Zip</a>&lt;Self, St&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;St: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>,</span></h4></section></summary><div class='docblock'>An adapter for zipping two streams together. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.zip">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.chain" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1470-1473">source</a><a href="#method.chain" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.chain" class="fnname">chain</a>&lt;St&gt;(self, other: St) -&gt; <a class="struct" href="../../futures_util/stream/stream/chain/struct.Chain.html" title="struct futures_util::stream::stream::chain::Chain">Chain</a>&lt;Self, St&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;St: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt;,</span></h4></section></summary><div class='docblock'>Adapter for chaining two streams. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.chain">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.peekable" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1481-1483">source</a><a href="#method.peekable" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.peekable" class="fnname">peekable</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/stream/peek/struct.Peekable.html" title="struct futures_util::stream::stream::peek::Peekable">Peekable</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Creates a new stream which exposes a <code>peek</code> method. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.peekable">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.chunks" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1507-1509">source</a><a href="#method.chunks" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.chunks" class="fnname">chunks</a>(self, capacity: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/stream/chunks/struct.Chunks.html" title="struct futures_util::stream::stream::chunks::Chunks">Chunks</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>An adaptor for chunking up items of the stream inside a vector. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.chunks">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.ready_chunks" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1532-1534">source</a><a href="#method.ready_chunks" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.ready_chunks" class="fnname">ready_chunks</a>(self, capacity: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/stream/ready_chunks/struct.ReadyChunks.html" title="struct futures_util::stream::stream::ready_chunks::ReadyChunks">ReadyChunks</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>An adaptor for chunking up ready items of the stream inside a vector. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.ready_chunks">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.inspect" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1592-1595">source</a><a href="#method.inspect" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.inspect" class="fnname">inspect</a>&lt;F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/stream/struct.Inspect.html" title="struct futures_util::stream::stream::Inspect">Inspect</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>),</span></h4></section></summary><div class='docblock'>Do something with each item of this stream, afterwards passing it on. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.inspect">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.left_stream" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1605-1608">source</a><a href="#method.left_stream" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.left_stream" class="fnname">left_stream</a>&lt;B&gt;(self) -&gt; <a class="enum" href="../../futures_util/future/either/enum.Either.html" title="enum futures_util::future::either::Either">Either</a>&lt;Self, B&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;B: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt;,</span></h4></section></summary><div class='docblock'>Wrap this stream in an <code>Either</code> stream, making it the left-hand variant
of that <code>Either</code>. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.left_stream">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.right_stream" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1618-1621">source</a><a href="#method.right_stream" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.right_stream" class="fnname">right_stream</a>&lt;B&gt;(self) -&gt; <a class="enum" href="../../futures_util/future/either/enum.Either.html" title="enum futures_util::future::either::Either">Either</a>&lt;B, Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;B: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&lt;Item = Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt;,</span></h4></section></summary><div class='docblock'>Wrap this stream in an <code>Either</code> stream, making it the right-hand variant
of that <code>Either</code>. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.right_stream">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.poll_next_unpin" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1628-1630">source</a><a href="#method.poll_next_unpin" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.poll_next_unpin" class="fnname">poll_next_unpin</a>(&amp;mut self, cx: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/task/wake/struct.Context.html" title="struct core::task::wake::Context">Context</a>&lt;'_&gt;) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/task/poll/enum.Poll.html" title="enum core::task::poll::Poll">Poll</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.Stream.html#associatedtype.Item" title="type futures_core::stream::Stream::Item">Item</a>&gt;&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h4></section></summary><div class='docblock'>A convenience method for calling <a href="../../futures_core/stream/trait.Stream.html#tymethod.poll_next" title="Stream::poll_next"><code>Stream::poll_next</code></a> on <a href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="Unpin"><code>Unpin</code></a>
stream types. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.poll_next_unpin">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.select_next_some" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/stream/mod.rs.html#1685-1687">source</a><a href="#method.select_next_some" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.select_next_some" class="fnname">select_next_some</a>(&amp;mut self) -&gt; <a class="struct" href="../../futures_util/stream/stream/select_next_some/struct.SelectNextSome.html" title="struct futures_util::stream::stream::select_next_some::SelectNextSome">SelectNextSome</a>&lt;'_, Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a> + <a class="trait" href="../../futures_core/stream/trait.FusedStream.html" title="trait futures_core::stream::FusedStream">FusedStream</a>,</span></h4></section></summary><div class='docblock'>Returns a <a href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="Future"><code>Future</code></a> that resolves when the next item in this stream is
ready. <a href="../../futures_util/stream/stream/trait.StreamExt.html#method.select_next_some">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-TryFrom%3CU%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#775">source</a><a href="#impl-TryFrom%3CU%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, U&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html" title="trait core::convert::TryFrom">TryFrom</a>&lt;U&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;U: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;T&gt;,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle" open><summary><section id="associatedtype.Error-3" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Error-3" class="anchor"></a><h4 class="code-header">type <a href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html#associatedtype.Error" class="associatedtype">Error</a> = <a class="enum" href="https://doc.rust-lang.org/nightly/core/convert/enum.Infallible.html" title="enum core::convert::Infallible">Infallible</a></h4></section></summary><div class='docblock'>The type returned in the event of a conversion error.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_from" class="method trait-impl has-srclink"><span class="rightside"><span class="since" title="const unstable">const: <a href="https://github.com/rust-lang/rust/issues/88674" title="Tracking issue for const_convert">unstable</a></span> · <a class="srclink" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#781">source</a></span><a href="#method.try_from" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html#tymethod.try_from" class="fnname">try_from</a>(value: U) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;T, &lt;T as <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html" title="trait core::convert::TryFrom">TryFrom</a>&lt;U&gt;&gt;::<a class="associatedtype" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html#associatedtype.Error" title="type core::convert::TryFrom::Error">Error</a>&gt;</h4></section></summary><div class='docblock'>Performs the conversion.</div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-TryInto%3CU%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#760">source</a><a href="#impl-TryInto%3CU%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T, U&gt; <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryInto.html" title="trait core::convert::TryInto">TryInto</a>&lt;U&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;U: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html" title="trait core::convert::TryFrom">TryFrom</a>&lt;T&gt;,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle" open><summary><section id="associatedtype.Error-2" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Error-2" class="anchor"></a><h4 class="code-header">type <a href="https://doc.rust-lang.org/nightly/core/convert/trait.TryInto.html#associatedtype.Error" class="associatedtype">Error</a> = &lt;U as <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html" title="trait core::convert::TryFrom">TryFrom</a>&lt;T&gt;&gt;::<a class="associatedtype" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html#associatedtype.Error" title="type core::convert::TryFrom::Error">Error</a></h4></section></summary><div class='docblock'>The type returned in the event of a conversion error.</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_into" class="method trait-impl has-srclink"><span class="rightside"><span class="since" title="const unstable">const: <a href="https://github.com/rust-lang/rust/issues/88674" title="Tracking issue for const_convert">unstable</a></span> · <a class="srclink" href="https://doc.rust-lang.org/nightly/src/core/convert/mod.rs.html#766">source</a></span><a href="#method.try_into" class="anchor"></a><h4 class="code-header">fn <a href="https://doc.rust-lang.org/nightly/core/convert/trait.TryInto.html#tymethod.try_into" class="fnname">try_into</a>(self) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;U, &lt;U as <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html" title="trait core::convert::TryFrom">TryFrom</a>&lt;T&gt;&gt;::<a class="associatedtype" href="https://doc.rust-lang.org/nightly/core/convert/trait.TryFrom.html#associatedtype.Error" title="type core::convert::TryFrom::Error">Error</a>&gt;</h4></section></summary><div class='docblock'>Performs the conversion.</div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-TryStream-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/futures_core/stream.rs.html#185">source</a><a href="#impl-TryStream-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;S, T, E&gt; <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a> for S<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;S: <a class="trait" href="../../futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a>&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;T, E&gt;&gt; + ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle" open><summary><section id="associatedtype.Ok" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Ok" class="anchor"></a><h4 class="code-header">type <a href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" class="associatedtype">Ok</a> = T</h4></section></summary><div class='docblock'>The type of successful values yielded by this future</div></details><details class="rustdoc-toggle" open><summary><section id="associatedtype.Error-4" class="associatedtype trait-impl has-srclink"><a href="#associatedtype.Error-4" class="anchor"></a><h4 class="code-header">type <a href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" class="associatedtype">Error</a> = E</h4></section></summary><div class='docblock'>The type of failures yielded by this future</div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_poll_next" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_core/stream.rs.html#192-195">source</a><a href="#method.try_poll_next" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_core/stream/trait.TryStream.html#tymethod.try_poll_next" class="fnname">try_poll_next</a>(<br>&nbsp;&nbsp;&nbsp;&nbsp;self: <a class="struct" href="https://doc.rust-lang.org/nightly/core/pin/struct.Pin.html" title="struct core::pin::Pin">Pin</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.reference.html">&amp;mut </a>S&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;cx: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/task/wake/struct.Context.html" title="struct core::task::wake::Context">Context</a>&lt;'_&gt;<br>) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/task/poll/enum.Poll.html" title="enum core::task::poll::Poll">Poll</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;&lt;S as <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&gt;::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>, &lt;S as <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&gt;::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;&gt;&gt;</h4></section></summary><div class='docblock'>Poll this <code>TryStream</code> as if it were a <code>Stream</code>. <a href="../../futures_core/stream/trait.TryStream.html#tymethod.try_poll_next">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-TryStreamExt-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#163">source</a><a href="#impl-TryStreamExt-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;S&gt; <a class="trait" href="../../futures_util/stream/try_stream/trait.TryStreamExt.html" title="trait futures_util::stream::try_stream::TryStreamExt">TryStreamExt</a> for S<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;S: <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a> + ?<a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Sized.html" title="trait core::marker::Sized">Sized</a>,</span></h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.err_into" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#184-187">source</a><a href="#method.err_into" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.err_into" class="fnname">err_into</a>&lt;E&gt;(self) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/struct.ErrInto.html" title="struct futures_util::stream::try_stream::ErrInto">ErrInto</a>&lt;Self, E&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;E&gt;,</span></h4></section></summary><div class='docblock'>Wraps the current stream in a new stream which converts the error type
into the one provided. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.err_into">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_ok" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#209-212">source</a><a href="#method.map_ok" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.map_ok" class="fnname">map_ok</a>&lt;T, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/struct.MapOk.html" title="struct futures_util::stream::try_stream::MapOk">MapOk</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; T,</span></h4></section></summary><div class='docblock'>Wraps the current stream in a new stream which maps the success value
using the provided closure. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.map_ok">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.map_err-1" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#234-237">source</a><a href="#method.map_err-1" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.map_err" class="fnname">map_err</a>&lt;E, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/struct.MapErr.html" title="struct futures_util::stream::try_stream::MapErr">MapErr</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>) -&gt; E,</span></h4></section></summary><div class='docblock'>Wraps the current stream in a new stream which maps the error value
using the provided closure. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.map_err">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.and_then-1" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#280-284">source</a><a href="#method.and_then-1" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.and_then" class="fnname">and_then</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/and_then/struct.AndThen.html" title="struct futures_util::stream::try_stream::and_then::AndThen">AndThen</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Chain on a computation for when a value is ready, passing the successful
results to the provided closure <code>f</code>. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.and_then">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.or_else" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#306-310">source</a><a href="#method.or_else" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.or_else" class="fnname">or_else</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/or_else/struct.OrElse.html" title="struct futures_util::stream::try_stream::or_else::OrElse">OrElse</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Ok = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>&gt;,</span></h4></section></summary><div class='docblock'>Chain on a computation for when an error happens, passing the
erroneous result to the provided closure <code>f</code>. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.or_else">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.inspect_ok" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#321-324">source</a><a href="#method.inspect_ok" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.inspect_ok" class="fnname">inspect_ok</a>&lt;F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/struct.InspectOk.html" title="struct futures_util::stream::try_stream::InspectOk">InspectOk</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>),</span></h4></section></summary><div class='docblock'>Do something with the success value of this stream, afterwards passing
it on. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.inspect_ok">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.inspect_err" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#334-337">source</a><a href="#method.inspect_err" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.inspect_err" class="fnname">inspect_err</a>&lt;F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/struct.InspectErr.html" title="struct futures_util::stream::try_stream::InspectErr">InspectErr</a>&lt;Self, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>),</span></h4></section></summary><div class='docblock'>Do something with the error value of this stream, afterwards passing it on. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.inspect_err">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.into_stream" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#363-365">source</a><a href="#method.into_stream" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.into_stream" class="fnname">into_stream</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/into_stream/struct.IntoStream.html" title="struct futures_util::stream::try_stream::into_stream::IntoStream">IntoStream</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Wraps a <a href="../../futures_core/stream/trait.TryStream.html" title="TryStream"><code>TryStream</code></a> into a type that implements
<a href="../../futures_core/stream/trait.Stream.html"><code>Stream</code></a> <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.into_stream">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_next" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#390-392">source</a><a href="#method.try_next" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_next" class="fnname">try_next</a>(&amp;mut self) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_next/struct.TryNext.html" title="struct futures_util::stream::try_stream::try_next::TryNext">TryNext</a>&lt;'_, Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h4></section></summary><div class='docblock'>Creates a future that attempts to resolve the next item in the stream.
If an error is encountered before the next item, the error is returned
instead. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_next">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_for_each" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#430-434">source</a><a href="#method.try_for_each" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_for_each" class="fnname">try_for_each</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_for_each/struct.TryForEach.html" title="struct futures_util::stream::try_stream::try_for_each::TryForEach">TryForEach</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Ok = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.unit.html">()</a>, Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Attempts to run this stream to completion, executing the provided
asynchronous closure for each element on the stream. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_for_each">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_skip_while" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#460-464">source</a><a href="#method.try_skip_while" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_skip_while" class="fnname">try_skip_while</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_skip_while/struct.TrySkipWhile.html" title="struct futures_util::stream::try_stream::try_skip_while::TrySkipWhile">TrySkipWhile</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Ok = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>, Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Skip elements on this stream while the provided asynchronous predicate
resolves to <code>true</code>. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_skip_while">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_take_while" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#490-494">source</a><a href="#method.try_take_while" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_take_while" class="fnname">try_take_while</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_take_while/struct.TryTakeWhile.html" title="struct futures_util::stream::try_stream::try_take_while::TryTakeWhile">TryTakeWhile</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Ok = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>, Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Take elements on this stream while the provided asynchronous predicate
resolves to <code>true</code>. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_take_while">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_for_each_concurrent" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#542-550">source</a><a href="#method.try_for_each_concurrent" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_for_each_concurrent" class="fnname">try_for_each_concurrent</a>&lt;Fut, F&gt;(<br>&nbsp;&nbsp;&nbsp;&nbsp;self,<br>&nbsp;&nbsp;&nbsp;&nbsp;limit: impl <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>&gt;&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;f: F<br>) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_for_each_concurrent/struct.TryForEachConcurrent.html" title="struct futures_util::stream::try_stream::try_for_each_concurrent::TryForEachConcurrent">TryForEachConcurrent</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <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="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.unit.html">()</a>, Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;&gt;,</span></h4></section></summary><div class='docblock'>Attempts to run this stream to completion, executing the provided asynchronous
closure for each element on the stream concurrently as elements become
available, exiting as soon as an error occurs. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_for_each_concurrent">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_collect" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#589-591">source</a><a href="#method.try_collect" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_collect" class="fnname">try_collect</a>&lt;C&gt;(self) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_collect/struct.TryCollect.html" title="struct futures_util::stream::try_stream::try_collect::TryCollect">TryCollect</a>&lt;Self, C&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;C: <a class="trait" href="https://doc.rust-lang.org/nightly/core/default/trait.Default.html" title="trait core::default::Default">Default</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.Extend.html" title="trait core::iter::traits::collect::Extend">Extend</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>&gt;,</span></h4></section></summary><div class='docblock'>Attempt to transform a stream into a collection,
returning a future representing the result of that computation. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_collect">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_chunks" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#634-636">source</a><a href="#method.try_chunks" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_chunks" class="fnname">try_chunks</a>(self, capacity: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_chunks/struct.TryChunks.html" title="struct futures_util::stream::try_stream::try_chunks::TryChunks">TryChunks</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>An adaptor for chunking up successful items of the stream inside a vector. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_chunks">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_filter" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#673-677">source</a><a href="#method.try_filter" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_filter" class="fnname">try_filter</a>&lt;Fut, F&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_filter/struct.TryFilter.html" title="struct futures_util::stream::try_stream::try_filter::TryFilter">TryFilter</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="https://doc.rust-lang.org/nightly/core/future/future/trait.Future.html" title="trait core::future::future::Future">Future</a>&lt;Output = <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.bool.html">bool</a>&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(&amp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,</span></h4></section></summary><div class='docblock'>Attempt to filter the values produced by this stream according to the
provided asynchronous closure. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_filter">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_filter_map" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#714-718">source</a><a href="#method.try_filter_map" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_filter_map" class="fnname">try_filter_map</a>&lt;Fut, F, T&gt;(self, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_filter_map/struct.TryFilterMap.html" title="struct futures_util::stream::try_stream::try_filter_map::TryFilterMap">TryFilterMap</a>&lt;Self, Fut, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Ok = <a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;T&gt;, Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,</span></h4></section></summary><div class='docblock'>Attempt to filter the values produced by this stream while
simultaneously mapping them to a different type according to the
provided asynchronous closure. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_filter_map">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_flatten_unordered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#769-773">source</a><a href="#method.try_flatten_unordered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_flatten_unordered" class="fnname">try_flatten_unordered</a>(<br>&nbsp;&nbsp;&nbsp;&nbsp;self,<br>&nbsp;&nbsp;&nbsp;&nbsp;limit: impl <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>&gt;&gt;<br>) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_flatten_unordered/struct.TryFlattenUnordered.html" title="struct futures_util::stream::try_stream::try_flatten_unordered::TryFlattenUnordered">TryFlattenUnordered</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>: <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a> as <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&gt;::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Flattens a stream of streams into just one continuous stream. Produced streams
will be polled concurrently and any errors will be passed through without looking at them.
If the underlying base stream returns an error, it will be <strong>immediately</strong> propagated. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_flatten_unordered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_flatten" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#822-826">source</a><a href="#method.try_flatten" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_flatten" class="fnname">try_flatten</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_flatten/struct.TryFlatten.html" title="struct futures_util::stream::try_stream::try_flatten::TryFlatten">TryFlatten</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>: <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>,<br>&nbsp;&nbsp;&nbsp;&nbsp;&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a> as <a class="trait" href="../../futures_core/stream/trait.TryStream.html" title="trait futures_core::stream::TryStream">TryStream</a>&gt;::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.From.html" title="trait core::convert::From">From</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Flattens a stream of streams into just one continuous stream. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_flatten">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_fold" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#861-865">source</a><a href="#method.try_fold" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_fold" class="fnname">try_fold</a>&lt;T, Fut, F&gt;(self, init: T, f: F) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_fold/struct.TryFold.html" title="struct futures_util::stream::try_stream::try_fold::TryFold">TryFold</a>&lt;Self, Fut, T, F&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;F: <a class="trait" href="https://doc.rust-lang.org/nightly/core/ops/function/trait.FnMut.html" title="trait core::ops::function::FnMut">FnMut</a>(T, Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>) -&gt; Fut,<br>&nbsp;&nbsp;&nbsp;&nbsp;Fut: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Ok = T, Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Attempt to execute an accumulating asynchronous computation over a
stream, collecting all the values into one final result. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_fold">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_concat" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#904-907">source</a><a href="#method.try_concat" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_concat" class="fnname">try_concat</a>(self) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_concat/struct.TryConcat.html" title="struct futures_util::stream::try_stream::try_concat::TryConcat">TryConcat</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>: <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.Extend.html" title="trait core::iter::traits::collect::Extend">Extend</a>&lt;&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a> as <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.IntoIterator.html" title="trait core::iter::traits::collect::IntoIterator">IntoIterator</a>&gt;::<a class="associatedtype" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.IntoIterator.html#associatedtype.Item" title="type core::iter::traits::collect::IntoIterator::Item">Item</a>&gt; + <a class="trait" href="https://doc.rust-lang.org/nightly/core/iter/traits/collect/trait.IntoIterator.html" title="trait core::iter::traits::collect::IntoIterator">IntoIterator</a> + <a class="trait" href="https://doc.rust-lang.org/nightly/core/default/trait.Default.html" title="trait core::default::Default">Default</a>,</span></h4></section></summary><div class='docblock'>Attempt to concatenate all items of a stream into a single
extendable destination, returning a future representing the end result. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_concat">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_buffer_unordered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#971-974">source</a><a href="#method.try_buffer_unordered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_buffer_unordered" class="fnname">try_buffer_unordered</a>(self, n: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_buffer_unordered/struct.TryBufferUnordered.html" title="struct futures_util::stream::try_stream::try_buffer_unordered::TryBufferUnordered">TryBufferUnordered</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Attempt to execute several futures from a stream concurrently (unordered). <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_buffer_unordered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_buffered" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#1047-1050">source</a><a href="#method.try_buffered" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_buffered" class="fnname">try_buffered</a>(self, n: <a class="primitive" href="https://doc.rust-lang.org/nightly/std/primitive.usize.html">usize</a>) -&gt; <a class="struct" href="../../futures_util/stream/try_stream/try_buffered/struct.TryBuffered.html" title="struct futures_util::stream::try_stream::try_buffered::TryBuffered">TryBuffered</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>: <a class="trait" href="../../futures_core/future/trait.TryFuture.html" title="trait futures_core::future::TryFuture">TryFuture</a>&lt;Error = Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;,</span></h4></section></summary><div class='docblock'>Attempt to execute several futures from a stream concurrently. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_buffered">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.try_poll_next_unpin" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/futures_util/stream/try_stream/mod.rs.html#1061-1066">source</a><a href="#method.try_poll_next_unpin" class="anchor"></a><h4 class="code-header">fn <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_poll_next_unpin" class="fnname">try_poll_next_unpin</a>(<br>&nbsp;&nbsp;&nbsp;&nbsp;&amp;mut self,<br>&nbsp;&nbsp;&nbsp;&nbsp;cx: &amp;mut <a class="struct" href="https://doc.rust-lang.org/nightly/core/task/wake/struct.Context.html" title="struct core::task::wake::Context">Context</a>&lt;'_&gt;<br>) -&gt; <a class="enum" href="https://doc.rust-lang.org/nightly/core/task/poll/enum.Poll.html" title="enum core::task::poll::Poll">Poll</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/option/enum.Option.html" title="enum core::option::Option">Option</a>&lt;<a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a>&lt;Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Ok" title="type futures_core::stream::TryStream::Ok">Ok</a>, Self::<a class="associatedtype" href="../../futures_core/stream/trait.TryStream.html#associatedtype.Error" title="type futures_core::stream::TryStream::Error">Error</a>&gt;&gt;&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;Self: <a class="trait" href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="trait core::marker::Unpin">Unpin</a>,</span></h4></section></summary><div class='docblock'>A convenience method for calling <a href="../../futures_core/stream/trait.TryStream.html#tymethod.try_poll_next" title="TryStream::try_poll_next"><code>TryStream::try_poll_next</code></a> on <a href="https://doc.rust-lang.org/nightly/core/marker/trait.Unpin.html" title="Unpin"><code>Unpin</code></a>
stream types. <a href="../../futures_util/stream/try_stream/trait.TryStreamExt.html#method.try_poll_next_unpin">Read more</a></div></details></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-VZip%3CV%3E-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/ppv_lite86/types.rs.html#221">source</a><a href="#impl-VZip%3CV%3E-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;V, T&gt; <a class="trait" href="../../ppv_lite86/types/trait.VZip.html" title="trait ppv_lite86::types::VZip">VZip</a>&lt;V&gt; for T<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;V: <a class="trait" href="../../ppv_lite86/types/trait.MultiLane.html" title="trait ppv_lite86::types::MultiLane">MultiLane</a>&lt;T&gt;,</span></h3></section></summary><div class="impl-items"><section id="method.vzip" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/ppv_lite86/types.rs.html#226">source</a><a href="#method.vzip" class="anchor"></a><h4 class="code-header">fn <a href="../../ppv_lite86/types/trait.VZip.html#tymethod.vzip" class="fnname">vzip</a>(self) -&gt; V</h4></section></div></details><details class="rustdoc-toggle implementors-toggle"><summary><section id="impl-WithSubscriber-for-Constant%3CT%2C%20M%3E" class="impl has-srclink"><a class="srclink rightside" href="../../src/tracing/instrument.rs.html#334">source</a><a href="#impl-WithSubscriber-for-Constant%3CT%2C%20M%3E" class="anchor"></a><h3 class="code-header">impl&lt;T&gt; <a class="trait" href="../../tracing/instrument/trait.WithSubscriber.html" title="trait tracing::instrument::WithSubscriber">WithSubscriber</a> for T</h3></section></summary><div class="impl-items"><details class="rustdoc-toggle method-toggle" open><summary><section id="method.with_subscriber" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tracing/instrument.rs.html#169-171">source</a><a href="#method.with_subscriber" class="anchor"></a><h4 class="code-header">fn <a href="../../tracing/instrument/trait.WithSubscriber.html#method.with_subscriber" class="fnname">with_subscriber</a>&lt;S&gt;(self, subscriber: S) -&gt; <a class="struct" href="../../tracing/instrument/struct.WithDispatch.html" title="struct tracing::instrument::WithDispatch">WithDispatch</a>&lt;Self&gt;<span class="where fmt-newline">where<br>&nbsp;&nbsp;&nbsp;&nbsp;S: <a class="trait" href="https://doc.rust-lang.org/nightly/core/convert/trait.Into.html" title="trait core::convert::Into">Into</a>&lt;<a class="struct" href="../../tracing_core/dispatcher/struct.Dispatch.html" title="struct tracing_core::dispatcher::Dispatch">Dispatch</a>&gt;,</span></h4></section></summary><div class='docblock'>Attaches the provided <a href="../../tracing_core/subscriber/trait.Subscriber.html"><code>Subscriber</code></a> to this type, returning a
<a href="../../tracing/instrument/struct.WithDispatch.html" title="WithDispatch"><code>WithDispatch</code></a> wrapper. <a href="../../tracing/instrument/trait.WithSubscriber.html#method.with_subscriber">Read more</a></div></details><details class="rustdoc-toggle method-toggle" open><summary><section id="method.with_current_subscriber" class="method trait-impl has-srclink"><a class="srclink rightside" href="../../src/tracing/instrument.rs.html#221">source</a><a href="#method.with_current_subscriber" class="anchor"></a><h4 class="code-header">fn <a href="../../tracing/instrument/trait.WithSubscriber.html#method.with_current_subscriber" class="fnname">with_current_subscriber</a>(self) -&gt; <a class="struct" href="../../tracing/instrument/struct.WithDispatch.html" title="struct tracing::instrument::WithDispatch">WithDispatch</a>&lt;Self&gt;</h4></section></summary><div class='docblock'>Attaches the current <a href="../../tracing/dispatcher/index.html#setting-the-default-subscriber">default</a> <a href="../../tracing_core/subscriber/trait.Subscriber.html"><code>Subscriber</code></a> to this type, returning a
<a href="../../tracing/instrument/struct.WithDispatch.html" title="WithDispatch"><code>WithDispatch</code></a> wrapper. <a href="../../tracing/instrument/trait.WithSubscriber.html#method.with_current_subscriber">Read more</a></div></details></div></details></div></section></div></main><div id="rustdoc-vars" data-root-path="../../" data-current-crate="tower" data-themes="ayu,dark,light" data-resource-suffix="" data-rustdoc-version="1.66.0-nightly (5c8bff74b 2022-10-21)" ></div></body></html>