summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorCarl Lerche <me@carllerche.com>2019-06-24 12:34:30 -0700
committerGitHub <noreply@github.com>2019-06-24 12:34:30 -0700
commit06c473e62842d257ed275497ce906710ea3f8e19 (patch)
tree4ca6d337a892aa23266a761b35dc61e988e57954
parentaa99950b9c983b842bd2107bb771c277d09d495d (diff)
Update Tokio to use `std::future`. (#1120)
A first pass at updating Tokio to use `std::future`. Implementations of `Future` from the futures crate are updated to implement `Future` from std. Implementations of `Stream` are moved to a feature flag. This commits disables a number of crates that have not yet been updated.
-rw-r--r--.cirrus.yml13
-rw-r--r--Cargo.toml22
-rw-r--r--async-await/.cargo/config2
-rw-r--r--async-await/Cargo.toml31
-rw-r--r--async-await/README.md5
-rw-r--r--async-await/src/chat.rs131
-rw-r--r--async-await/src/echo_client.rs50
-rw-r--r--async-await/src/echo_server.rs42
-rw-r--r--async-await/src/hyper.rs29
-rw-r--r--async-await/tests/macros.rs22
-rw-r--r--azure-pipelines.yml184
-rw-r--r--ci/azure-install-rust.yml3
-rw-r--r--ci/azure-rustfmt.yml1
-rw-r--r--ci/azure-test-stable.yml25
-rw-r--r--tokio-current-thread/Cargo.toml4
-rw-r--r--tokio-current-thread/src/lib.rs111
-rw-r--r--tokio-current-thread/src/scheduler.rs170
-rw-r--r--tokio-current-thread/tests/current_thread.rs365
-rw-r--r--tokio-executor/Cargo.toml6
-rw-r--r--tokio-executor/src/enter.rs24
-rw-r--r--tokio-executor/src/executor.rs15
-rw-r--r--tokio-executor/src/global.rs33
-rw-r--r--tokio-executor/src/park.rs43
-rw-r--r--tokio-executor/tests/enter.rs18
-rw-r--r--tokio-executor/tests/executor.rs15
-rw-r--r--tokio-futures/Cargo.toml17
-rw-r--r--tokio-futures/README.md41
-rw-r--r--tokio-futures/src/async_wait.rs15
-rw-r--r--tokio-futures/src/compat/backward.rs86
-rw-r--r--tokio-futures/src/compat/forward.rs69
-rw-r--r--tokio-futures/src/compat/mod.rs42
-rw-r--r--tokio-futures/src/future.rs3
-rw-r--r--tokio-futures/src/io/flush.rs29
-rw-r--r--tokio-futures/src/io/mod.rs192
-rw-r--r--tokio-futures/src/io/read.rs32
-rw-r--r--tokio-futures/src/io/read_exact.rs50
-rw-r--r--tokio-futures/src/io/write.rs32
-rw-r--r--tokio-futures/src/io/write_all.rs51
-rw-r--r--tokio-futures/src/lib.rs32
-rw-r--r--tokio-futures/src/macros.rs12
-rw-r--r--tokio-futures/src/sink.rs68
-rw-r--r--tokio-futures/src/sink/mod.rs24
-rw-r--r--tokio-futures/src/sink/send.rs51
-rw-r--r--tokio-futures/src/stream.rs3
-rw-r--r--tokio-futures/src/stream/mod.rs38
-rw-r--r--tokio-futures/src/stream/next.rs28
-rw-r--r--tokio-io/Cargo.toml4
-rw-r--r--tokio-io/src/_tokio_codec/decoder.rs3
-rw-r--r--tokio-io/src/_tokio_codec/encoder.rs3
-rw-r--r--tokio-io/src/_tokio_codec/framed.rs281
-rw-r--r--tokio-io/src/_tokio_codec/framed_read.rs215
-rw-r--r--tokio-io/src/_tokio_codec/framed_write.rs245
-rw-r--r--tokio-io/src/_tokio_codec/mod.rs35
-rw-r--r--tokio-io/src/allow_std.rs93
-rw-r--r--tokio-io/src/async_read.rs122
-rw-r--r--tokio-io/src/async_write.rs132
-rw-r--r--tokio-io/src/codec/bytes_codec.rs42
-rw-r--r--tokio-io/src/codec/decoder.rs115
-rw-r--r--tokio-io/src/codec/encoder.rs25
-rw-r--r--tokio-io/src/codec/lines_codec.rs88
-rw-r--r--tokio-io/src/codec/mod.rs375
-rw-r--r--tokio-io/src/framed.rs246
-rw-r--r--tokio-io/src/framed_read.rs219
-rw-r--r--tokio-io/src/framed_write.rs249
-rw-r--r--tokio-io/src/io/copy.rs98
-rw-r--r--tokio-io/src/io/flush.rs41
-rw-r--r--tokio-io/src/io/mod.rs32
-rw-r--r--tokio-io/src/io/read.rs58
-rw-r--r--tokio-io/src/io/read_exact.rs83
-rw-r--r--tokio-io/src/io/read_to_end.rs64
-rw-r--r--tokio-io/src/io/read_until.rs74
-rw-r--r--tokio-io/src/io/shutdown.rs42
-rw-r--r--tokio-io/src/io/write_all.rs86
-rw-r--r--tokio-io/src/length_delimited.rs936
-rw-r--r--tokio-io/src/lib.rs44
-rw-r--r--tokio-io/src/lines.rs60
-rw-r--r--tokio-io/src/split.rs243
-rw-r--r--tokio-io/src/window.rs117
-rw-r--r--tokio-io/tests/async_read.rs180
-rw-r--r--tokio-io/tests/length_delimited.rs548
-rw-r--r--tokio-macros/Cargo.toml3
-rw-r--r--tokio-macros/src/lib.rs1
-rw-r--r--tokio-reactor/Cargo.toml3
-rw-r--r--tokio-reactor/benches/basic.rs2
-rw-r--r--tokio-reactor/src/background.rs214
-rw-r--r--tokio-reactor/src/lib.rs206
-rw-r--r--tokio-reactor/src/poll_evented.rs174
-rw-r--r--tokio-reactor/src/registration.rs100
-rw-r--r--tokio-sync/Cargo.toml14
-rw-r--r--tokio-sync/src/lib.rs13
-rw-r--r--tokio-sync/src/lock.rs14
-rw-r--r--tokio-sync/src/loom.rs3
-rw-r--r--tokio-sync/src/mpsc/bounded.rs65
-rw-r--r--tokio-sync/src/mpsc/chan.rs46
-rw-r--r--tokio-sync/src/mpsc/unbounded.rs44
-rw-r--r--tokio-sync/src/oneshot.rs90
-rw-r--r--tokio-sync/src/semaphore.rs73
-rw-r--r--tokio-sync/src/task/atomic_task.rs336
-rw-r--r--tokio-sync/src/task/atomic_waker.rs317
-rw-r--r--tokio-sync/src/task/mod.rs4
-rw-r--r--tokio-sync/src/watch.rs108
-rw-r--r--tokio-sync/tests/atomic_task.rs52
-rw-r--r--tokio-sync/tests/atomic_waker.rs37
-rw-r--r--tokio-sync/tests/errors.rs2
-rw-r--r--tokio-sync/tests/fuzz_atomic_waker.rs (renamed from tokio-sync/tests/fuzz_atomic_task.rs)27
-rw-r--r--tokio-sync/tests/fuzz_mpsc.rs7
-rw-r--r--tokio-sync/tests/fuzz_oneshot.rs65
-rw-r--r--tokio-sync/tests/fuzz_semaphore.rs63
-rw-r--r--tokio-sync/tests/lock.rs73
-rw-r--r--tokio-sync/tests/mpsc.rs351
-rw-r--r--tokio-sync/tests/oneshot.rs160
-rw-r--r--tokio-sync/tests/semaphore.rs102
-rw-r--r--tokio-sync/tests/watch.rs195
-rw-r--r--tokio-tcp/Cargo.toml13
-rw-r--r--tokio-tcp/src/incoming.rs14
-rw-r--r--tokio-tcp/src/lib.rs16
-rw-r--r--tokio-tcp/src/listener.rs42
-rw-r--r--tokio-tcp/src/stream.rs175
-rw-r--r--tokio-test/Cargo.toml5
-rw-r--r--tokio-test/src/lib.rs6
-rw-r--r--tokio-test/src/macros.rs76
-rw-r--r--tokio-test/src/task.rs145
-rw-r--r--tokio-timer/Cargo.toml20
-rw-r--r--tokio-timer/src/delay.rs26
-rw-r--r--tokio-timer/src/delay_queue.rs56
-rw-r--r--tokio-timer/src/interval.rs15
-rw-r--r--tokio-timer/src/lib.rs19
-rw-r--r--tokio-timer/src/throttle.rs137
-rw-r--r--tokio-timer/src/timeout.rs178
-rw-r--r--tokio-timer/src/timer/entry.rs35
-rw-r--r--tokio-timer/src/timer/handle.rs12
-rw-r--r--tokio-timer/src/timer/registration.rs11
-rw-r--r--tokio/Cargo.toml49
-rw-r--r--tokio/src/async_await.rs17
-rw-r--r--tokio/src/executor.rs (renamed from tokio/src/executor/mod.rs)40
-rw-r--r--tokio/src/executor/current_thread/mod.rs166
-rw-r--r--tokio/src/io.rs21
-rw-r--r--tokio/src/lib.rs17
-rw-r--r--tokio/src/net.rs20
-rw-r--r--tokio/src/prelude.rs13
-rw-r--r--tokio/src/reactor.rs (renamed from tokio/src/reactor/mod.rs)6
-rw-r--r--tokio/src/reactor/poll_evented.rs545
-rw-r--r--tokio/src/runtime/current_thread/async_await.rs17
-rw-r--r--tokio/src/runtime/current_thread/builder.rs24
-rw-r--r--tokio/src/runtime/current_thread/mod.rs13