into_stream.rs.html -- source

Files

base64

chunked_encoder.rs decode.rs display.rs encode.rs lib.rs line_wrap.rs tables.rs

byteorder

bytes

buf

buf.rs buf_mut.rs chain.rs from_buf.rs into_buf.rs iter.rs mod.rs reader.rs take.rs vec_deque.rs writer.rs

bytes.rs debug.rs lib.rs

cfg_if

crossbeam_deque

crossbeam_epoch

sync

list.rs mod.rs queue.rs

atomic.rs collector.rs default.rs deferred.rs epoch.rs guard.rs internal.rs lib.rs

crossbeam_queue

array_queue.rs err.rs lib.rs seg_queue.rs

crossbeam_utils

atomic

atomic_cell.rs consume.rs mod.rs seq_lock.rs

sync

mod.rs parker.rs sharded_lock.rs wait_group.rs

backoff.rs cache_padded.rs lib.rs thread.rs

fnv

futures

future

sink

buffer.rs fanout.rs flush.rs from_err.rs map_err.rs mod.rs send.rs send_all.rs wait.rs with.rs with_flat_map.rs

stream

sync

mpsc

mod.rs queue.rs

bilock.rs mod.rs oneshot.rs

task_impl

std

data.rs mod.rs task_rc.rs unpark_mutex.rs

atomic_task.rs core.rs mod.rs

unsync

mod.rs mpsc.rs oneshot.rs

executor.rs lib.rs lock.rs poll.rs resultstream.rs task.rs

futures_cpupool

httparse

simd

avx2.rs mod.rs sse42.rs

iter.rs lib.rs macros.rs

hyper

client

conn.rs connect.rs dispatch.rs dns.rs mod.rs pool.rs

common

header

common

accept.rs accept_charset.rs accept_encoding.rs accept_language.rs accept_ranges.rs access_control_allow_credentials.rs access_control_allow_headers.rs access_control_allow_methods.rs access_control_allow_origin.rs access_control_expose_headers.rs access_control_max_age.rs access_control_request_headers.rs access_control_request_method.rs allow.rs authorization.rs cache_control.rs connection.rs content_disposition.rs content_encoding.rs content_language.rs content_length.rs content_location.rs content_range.rs content_type.rs cookie.rs date.rs etag.rs expect.rs expires.rs from.rs host.rs if_match.rs if_modified_since.rs if_none_match.rs if_range.rs if_unmodified_since.rs last_event_id.rs last_modified.rs link.rs location.rs mod.rs origin.rs pragma.rs prefer.rs preference_applied.rs proxy_authorization.rs range.rs referer.rs referrer_policy.rs retry_after.rs server.rs set_cookie.rs strict_transport_security.rs te.rs transfer_encoding.rs upgrade.rs user_agent.rs vary.rs warning.rs

internals

cell.rs item.rs mod.rs vec_map.rs

shared

charset.rs encoding.rs entity.rs httpdate.rs mod.rs quality_item.rs

mod.rs parsing.rs raw.rs

proto

h1

conn.rs date.rs decode.rs dispatch.rs encode.rs io.rs mod.rs role.rs

body.rs chunk.rs mod.rs request.rs response.rs

server

conn.rs mod.rs server_proto.rs service.rs

error.rs lib.rs method.rs status.rs uri.rs version.rs

iovec

sys

language_tags

lazy_static

inline_lazy.rs lib.rs

libc

unix

linux_like

linux

gnu

b64

x86_64

align.rs mod.rs not_x32.rs

align.rs mod.rs

align.rs mod.rs

align.rs mod.rs

fixed_width_ints.rs lib.rs macros.rs

lock_api

lib.rs mutex.rs remutex.rs rwlock.rs

log

lib.rs macros.rs

maybe_uninit

memoffset

lib.rs offset_of.rs span_of.rs

mime

lib.rs parse.rs

mio

mio_uds

datagram.rs lib.rs listener.rs socket.rs stream.rs

net2

sys

unix

impls.rs mod.rs

ext.rs lib.rs socket.rs tcp.rs udp.rs unix.rs utils.rs

num_cpus

lib.rs linux.rs

parking_lot

condvar.rs deadlock.rs elision.rs lib.rs mutex.rs once.rs raw_mutex.rs raw_rwlock.rs remutex.rs rwlock.rs util.rs

parking_lot_core

thread_parker

linux.rs mod.rs

lib.rs parking_lot.rs spinwait.rs util.rs word_lock.rs

percent_encoding

proc_macro2

fallback.rs lib.rs strnom.rs wrapper.rs

quote

ext.rs format.rs ident_fragment.rs lib.rs runtime.rs spanned.rs to_tokens.rs

rand

distributions

lib.rs rand_impls.rs

relay

rfsapi

safemem

scoped_tls

scopeguard

serde

de

from_primitive.rs ignored_any.rs impls.rs mod.rs utf8.rs value.rs

private

de.rs macros.rs mod.rs ser.rs

ser

impls.rs impossible.rs mod.rs

export.rs integer128.rs lib.rs macros.rs

serde_derive

internals

ast.rs attr.rs case.rs check.rs ctxt.rs mod.rs symbol.rs

bound.rs de.rs dummy.rs fragment.rs lib.rs pretend.rs ser.rs try.rs

slab

smallvec

syn

take

time

display.rs duration.rs lib.rs parse.rs sys.rs

tokio

codec

length_delimited.rs mod.rs

executor

current_thread

reactor

mod.rs poll_evented.rs

runtime

current_thread

builder.rs mod.rs runtime.rs

threadpool

builder.rs mod.rs shutdown.rs task_executor.rs

util

enumerate.rs future.rs mod.rs stream.rs

clock.rs fs.rs io.rs lib.rs net.rs prelude.rs sync.rs timer.rs

tokio_codec

bytes_codec.rs lib.rs lines_codec.rs

tokio_core

tokio_current_thread

lib.rs scheduler.rs

tokio_executor

enter.rs error.rs executor.rs global.rs lib.rs park.rs typed.rs

tokio_fs

tokio_io

tokio_proto

simple

multiplex

client.rs mod.rs server.rs

pipeline

client.rs mod.rs server.rs

streaming

multiplex

advanced.rs client.rs frame.rs frame_buf.rs mod.rs server.rs

pipeline

advanced.rs client.rs frame.rs mod.rs server.rs

body.rs message.rs mod.rs

util

client_proxy.rs mod.rs

buffer_one.rs lib.rs tcp_client.rs tcp_server.rs

tokio_reactor

background.rs lib.rs poll_evented.rs registration.rs sharded_rwlock.rs

tokio_service

tokio_sync

mpsc

block.rs bounded.rs chan.rs list.rs mod.rs unbounded.rs

task

atomic_task.rs mod.rs

lib.rs lock.rs loom.rs oneshot.rs semaphore.rs watch.rs

tokio_tcp

incoming.rs lib.rs listener.rs stream.rs

tokio_threadpool

tokio_timer

tokio_udp

frame.rs lib.rs recv_dgram.rs send_dgram.rs socket.rs

tokio_uds

datagram.rs frame.rs incoming.rs lib.rs listener.rs recv_dgram.rs send_dgram.rs stream.rs ucred.rs

try_lock

unicase

unicode

ascii.rs lib.rs

unicode_xid

lib.rs tables.rs

want

use {Async, Poll};
use Future;
use stream::Stream;

/// Future that forwards one element from the underlying future
/// (whether it is success of error) and emits EOF after that.
#[derive(Debug)]
pub struct IntoStream<F: Future> {
    future: Option<F>
}

pub fn new<F: Future>(future: F) -> IntoStream<F> {
    IntoStream {
        future: Some(future)
    }
}

impl<F: Future> Stream for IntoStream<F> {
    type Item = F::Item;
    type Error = F::Error;

    fn poll(&mut self) -> Poll<Option<Self::Item>, Self::Error> {
        let ret = match self.future {
            None => return Ok(Async::Ready(None)),
            Some(ref mut future) => {
                match future.poll() {
                    Ok(Async::NotReady) => return Ok(Async::NotReady),
                    Err(e) => Err(e),
                    Ok(Async::Ready(r)) => Ok(r),
                }
            }
        };
        self.future = None;
        ret.map(|r| Async::Ready(Some(r)))
    }
}

Keyboard Shortcuts

?: Show this help dialog
S: Focus the search field
↑: Move up in search results
↓: Move down in search results
↹: Switch tab
⏎: Go to active search result
+: Expand all sections
-: Collapse all sections

Search Tricks

Prefix searches with a type followed by a colon (e.g., fn:) to restrict the search to a given type.

Accepted types are: fn, mod, struct, enum, trait, type, macro, and const.

Search functions by type signature (e.g., vec -> usize or * -> vec)

Search multiple things at once by splitting your query with comma (e.g., str,u8 or String,struct:Vec,test)

You can look for items with an exact name by putting double quotes around your request: "string"

Look for items inside another one by searching for a path: vec::Vec