tokio-stream

chore: prepare tokio-stream v0.1.19 (#8310)

Added

• stream: implement FromStream for standard collections (#7954, #7966)
• stream: implement FusedStream for various stream adaptors (#7854, #8090, #8096)
• stream: implement Peekable::size_hint (#8109)
• task: add JoinSetStream wrapper for JoinSet (#8189)

Changed

• stream: bump minimum required tokio version to 1.38.0 (#7887)
• stream: use cooperative budgeting in tokio_stream::iter (#8218)
• stream: update coop handling for empty and once (#8227)

Fixed

• stream: fix overflow in StreamMap::size_hint (#8216)
• stream: honor StreamMap::next_many limit (#8215)
• stream: stop polling underlying stream once map_while yields None (#8233)

Added

• Re-export tokio::sync::Mutex primitive (#964).

Added

• stream: add ChunksTimeout::into_remainder (#7715)
• stream: add examples to wrapper types (#7024)
• sync: implement Stream::size_hint for ReceiverStream and UnboundedReceiverStream (#7492)

Fixed

• stream: work around the rustc bug in StreamExt::collect (#7754)

Documented

• stream: improve the docs of TcpListenerStream (#7578)

Added

• TypedExecutor re-export and implementations (#993).

• deps: fix dev-dependency on tokio-test (#6931, #7019)
• stream: fix link on Peekable (#6861)
• sync: fix Stream link in broadcast docs (#6873)

Added

• Propagate trace subscriber in the runtime (#966).

This release bumps the MSRV of tokio-stream to 1.70.

• stream: add next_many and poll_next_many to StreamMap (#6409)
• stream: make stream adapters public (#6658)
• readme: add readme for tokio-stream (#6456)

Fixed

• async-await: track latest nightly changes (#940).

Added

• sync::Watch, a single value broadcast channel (#922).
• Async equivalent of read / write file helpers being added to std (#896).

This release bumps the MSRV of tokio-stream to 1.63.

• docs: fix typo in argument name (#6389)
• docs: fix typo in peekable docs (#6130)
• docs: link to latest version of tokio-util docs (#5694)
• docs: typographic improvements (#6262)
• stream: add StreamExt::peekable (#6095)

Added

• Re-export tokio-sync APIs (#839).
• Stream enumerate combinator (#832).

This bugfix release bumps the minimum version of Tokio to 1.15, which is necessary for timeout_repeating to compile. (#5657)

• Use feature flags to break up the crate, allowing users to pick & choose components (#808).
• Export UnixDatagram and UnixDatagramFramed (#772).

This release bumps the MSRV of tokio-stream to 1.56.

• stream: add "full" feature flag (#5639)
• stream: add StreamExt::timeout_repeating (#5577)
• stream: add StreamNotifyClose (#4851)

• Fix Runtime::reactor() when no tasks are spawned (#721).
• runtime::Builder no longer uses deprecated methods (#749).
• Provide after_start and before_stop configuration settings for Runtime (#756).
• Implement throttle stream combinator (#736).

• time: remove Unpin bound on Throttle methods (#5105)
• time: document that throttle operates on ms granularity (#5101)
• sync: add WatchStream::from_changes (#5432)

• runtime: expose keep_alive on runtime builder (#676).
• runtime: create a reactor per worker thread (#660).
• codec: fix panic in LengthDelimitedCodec (#682).
• io: re-export tokio_io::io::read function (#689).
• runtime: check for executor re-entry in more places (#708).

• time: allow StreamExt::chunks_timeout outside of a runtime (#5036)

• Fix tokio-async-await dependency (#675).

• time: add StreamExt::chunks_timeout (#4695)
• stream: add track_caller to public APIs (#4786)

• Fix minimal versions

• deps: upgrade tokio-util dependency to 0.7.x (#3762)
• stream: add StreamExt::map_while (#4351)
• stream: add StreamExt::then (#4355)
• stream: add cancel-safety docs to StreamExt::next and try_next (#4715)
• stream: expose Elapsed error (#4502)
• stream: expose Timeout (#4601)
• stream: implement Extend for StreamMap (#4272)
• sync: add Clone to RecvError types (#4560)

• Experimental async/await improvements (#661).
• Re-export TaskExecutor from tokio-current-thread (#652).
• Improve Runtime builder API (#645).
• tokio::run panics when called from the context of an executor (#646).
• Introduce StreamExt with a timeout helper (#573).
• Move length_delimited into tokio (#575).
• Re-organize tokio::net module (#548).
• Re-export tokio-current-thread::spawn in current_thread runtime (#579).

• stream: add From<Receiver<T>> impl for receiver streams (#4080)
• stream: impl FromIterator for StreamMap (#4052)
• signal: make windows docs for signal module show up on unix builds (#3770)

• Extract tokio::executor::current_thread to a sub crate (#370)
• Add Runtime::block_on (#398)
• Add runtime::current_thread::block_on_all (#477)
• Misc documentation improvements (#450)
• Implement std::error::Error for error types (#501)

Fixed

• sync: fix watch wrapper (#3914)
• time: fix Timeout::size_hint (#3902)

• Add Runtime::block_on for concurrent runtime (#391).
• Provide handle to current_thread::Runtime that allows spawning tasks from other threads (#340).
• Provide clock::now(), a configurable source of time (#381).

Added

• stream: implement Error and Display for BroadcastStreamRecvError (#3745)

Fixed

• stream: avoid yielding in AllFuture and AnyFuture (#3625)

• Add asynchronous filesystem APIs (#323).
• Add "current thread" runtime variant (#308).
• CurrentThread: Expose inner Park instance.
• Improve fairness of CurrentThread executor (#313).

Fixed

• stream: documentation note for throttle Unpin (#3600)

• Provide timer API (#266)

Added

• signal: add Signal wrapper (#3510)

Fixed

• stream: remove duplicate doc_cfg declaration (#3561)
• sync: yield initial value in WatchStream (#3576)

• Fix build on FreeBSD (#218)
• Shutdown the Runtime when the handle is dropped (#214)
• Set Runtime thread name prefix for worker threads (#232)
• Add builder for Runtime (#234)
• Extract TCP and UDP types into separate crates (#224)
• Optionally support futures 0.2.

Added

• sync: add wrapper for broadcast and watch (#3384, #3504)

• Fix CurrentThread::turn to block on idle (#212).

Fixed

• docs: fix some wrappers missing in documentation (#3378)

• 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)

Added

• add Stream wrappers (#3343)

Fixed

• move async-stream to dev-dependencies (#3366)

• Doc fixes

• Initial release

• Initial crate released based on RFC.