tokio-timer

Fixes

• macros: unresolved import in pin! (#2281).

Fixes

• net: UnixStream::poll_shutdown should call shutdown(Write) (#2245).
• process: Wake up read and write on EPOLLERR (#2218).
• rt: potential deadlock when using block_in_place and shutting down the runtime (#2119).
• rt: only detect number of CPUs if core_threads not specified (#2238).
• sync: reduce watch::Receiver struct size (#2191).
• time: succeed when setting delay of $MAX-1 (#2184).
• time: avoid having to poll DelayQueue after inserting new delay (#2217).

Added

• macros: pin! variant that assigns to identifier and pins (#2274).
• net: impl Stream for Listener types (#2275).
• rt: Runtime::shutdown_timeout waits for runtime to shutdown for specified duration (#2186).
• stream: StreamMap merges streams and can insert / remove streams at runtime (#2185).
• stream: StreamExt::skip() skips a fixed number of items (#2204).
• stream: StreamExt::skip_while() skips items based on a predicate (#2205).
• sync: Notify provides basic async / await task notification (#2210).
• sync: Mutex::into_inner retrieves guarded data (#2250).
• sync: mpsc::Sender::send_timeout sends, waiting for up to specified duration for channel capacity (#2227).
• time: impl Ord and Hash for Instant (#2239).

Fixes

• docs: misc fixes and tweaks (#2155, #2103, #2027, #2167, #2175).
• macros: handle generics in #[tokio::main] method (#2177).
• sync: broadcast potential lost notifications (#2135).
• rt: improve "no runtime" panic messages (#2145).

Added

• optional support for using parking_lot internally (#2164).
• fs: fs::copy, an async version of std::fs::copy (#2079).
• macros: select! waits for the first branch to complete (#2152).
• macros: join! waits for all branches to complete (#2158).
• macros: try_join! waits for all branches to complete or the first error (#2169).
• macros: pin! pins a value to the stack (#2163).
• net: ReadHalf::poll() and ReadHalf::poll_peak (#2151)
• stream: StreamExt::timeout() sets a per-item max duration (#2149).
• stream: StreamExt::fold() applies a function, producing a single value. (#2122).
• sync: impl Eq, PartialEq for oneshot::RecvError (#2168).
• task: methods for inspecting the JoinError cause (#2051).

Fixes

• #[tokio::main] when rt-core feature flag is not enabled (#2139).
• remove AsyncBufRead from BufStream impl block (#2108).
• potential undefined behavior when implementing AsyncRead incorrectly (#2030).

Added

• BufStream::with_capacity (#2125).
• impl From and Default for RwLock (#2089).
• io::ReadHalf::is_pair_of checks if provided WriteHalf is for the same underlying object (#1762, #2144).
• runtime::Handle::try_current() returns a handle to the current runtime (#2118).
• stream::empty() returns an immediately ready empty stream (#2092).
• stream::once(val) returns a stream that yields a single value: val (#2094).
• stream::pending() returns a stream that never becomes ready (#2092).
• StreamExt::chain() sequences a second stream after the first completes (#2093).
• StreamExt::collect() transform a stream into a collection (#2109).
• StreamExt::fuse ends the stream after the first None (#2085).
• StreamExt::merge combines two streams, yielding values as they become ready (#2091).
• Task-local storage (#2126).

Fixes

• AsyncSeek impl for File (#1986).
• rt: shutdown deadlock in threaded_scheduler (#2074, #2082).
• rt: memory ordering when dropping JoinHandle (#2044).
• docs: misc API documentation fixes and improvements.

Fixes

• depend on new version of tokio-macros.

Fixes

• potential deadlock when dropping basic_scheduler Runtime.
• calling spawn_blocking from within a spawn_blocking (#2006).
• storing a Runtime instance in a thread-local (#2011).
• miscellaneous documentation fixes.
• rt: fix Waker::will_wake to return true when tasks match (#2045).
• test-util: time::advance runs pending tasks before changing the time (#2059).

Added

• net::lookup_host maps a T: ToSocketAddrs to a stream of SocketAddrs (#1870).
• process::Child fields are made public to match std (#2014).
• impl Stream for sync::broadcast::Receiver (#2012).
• sync::RwLock provides an asynchronous read-write lock (#1699).
• runtime::Handle::current returns the handle for the current runtime (#2040).
• StreamExt::filter filters stream values according to a predicate (#2001).
• StreamExt::filter_map simultaneously filter and map stream values (#2001).
• StreamExt::try_next convenience for streams of Result<T, E> (#2005).
• StreamExt::take limits a stream to a specified number of values (#2025).
• StreamExt::take_while limits a stream based on a predicate (#2029).
• StreamExt::all tests if every element of the stream matches a predicate (#2035).
• StreamExt::any tests if any element of the stream matches a predicate (#2034).
• task::LocalSet.await runs spawned tasks until the set is idle (#1971).
• time::DelayQueue::len returns the number entries in the queue (#1755).
• expose runtime options from the #[tokio::main] and #[tokio::test] (#2022).

Fixes

• fs::File::seek API regression (#1991).

Added

• io::AsyncSeek trait (#1924).
• Mutex::try_lock (#1939)
• mpsc::Receiver::try_recv and mpsc::UnboundedReceiver::try_recv (#1939).
• writev support for TcpStream (#1956).
• time::throttle for throttling streams (#1949).
• implement Stream for time::DelayQueue (#1975).
• sync::broadcast provides a fan-out channel (#1943).
• sync::Semaphore provides an async semaphore (#1973).
• stream::StreamExt provides stream utilities (#1962).

Fixes

• deadlock risk while shutting down the runtime (#1972).
• panic while shutting down the runtime (#1978).
• sync::MutexGuard debug output (#1961).
• misc doc improvements (#1933, #1934, #1940, #1942).

Changes

• runtime threads are configured with runtime::Builder::core_threads and runtime::Builder::max_threads. runtime::Builder::num_threads is deprecated (#1977).

Fixes

• sync::Mutex deadlock when lock() future is dropped early (#1898).

Added

• read / write integers using AsyncReadExt and AsyncWriteExt (#1863).
• read_buf / write_buf for reading / writing Buf / BufMut (#1881).
• TcpStream::poll_peek - pollable API for performing TCP peek (#1864).
• sync::oneshot::error::TryRecvError provides variants to detect the error kind (#1874).
• LocalSet::block_on accepts !'static task (#1882).
• task::JoinError is now Sync (#1888).
• impl conversions between tokio::time::Instant and std::time::Instant (#1904).

Fixes

• calling spawn_blocking after runtime shutdown (#1875).
• LocalSet drop infinite loop (#1892).
• LocalSet hang under load (#1905).
• improved documentation (#1865, #1866, #1868, #1874, #1876, #1911).

Fixes

• API docs for TcpListener::incoming, UnixListener::incoming (#1831).

Added

• tokio::task::LocalSet provides a strategy for spawning !Send tasks (#1733).
• export tokio::time::Elapsed (#1826).
• impl AsRawFd, AsRawHandle for tokio::fs::File (#1827).

A major breaking change. Most implementation and APIs have changed one way or another. This changelog entry contains a highlight

Changed

• APIs are updated to use async / await.
• most tokio-* crates are collapsed into this crate.
• Scheduler is rewritten.
• tokio::spawn returns a JoinHandle.
• A single I/O / timer is used per runtime.
• I/O driver uses a concurrent slab for allocating state.
• components are made available via feature flag.
• Use bytes 0.5
• tokio::codec is moved to tokio-util.

Removed

• Standalone timer and net drivers are removed, use Runtime instead
• current_thread runtime is removed, use tokio::runtime::Runtime with basic_scheduler instead.

• Introduce Tokio Runtime (#141)
• Provide CurrentThread for more flexible usage of current thread executor (#141).
• Add Lio for platforms that support it (#142).
• I/O resources now lazily bind to the reactor (#160).
• Extract Reactor to dedicated crate (#169)
• Add facade to sub crates and add prelude (#166).
• Switch TCP/UDP fns to poll_ -> Poll<...> style (#175)

• Doc fixes

• Initial crate released based on RFC.