index
:
tokio
iter-into-stream
master
Contrib clone of tokio
matthias
summary
refs
log
tree
commit
diff
stats
log msg
author
committer
range
diff options
context:
1
2
3
4
5
6
7
8
9
10
15
20
25
30
35
40
space:
include
ignore
mode:
unified
ssdiff
stat only
Diffstat
-rw-r--r--
.cirrus.yml
13
-rw-r--r--
Cargo.toml
22
-rw-r--r--
async-await/.cargo/config
2
-rw-r--r--
async-await/Cargo.toml
31
-rw-r--r--
async-await/README.md
5
-rw-r--r--
async-await/src/chat.rs
131
-rw-r--r--
async-await/src/echo_client.rs
50
-rw-r--r--
async-await/src/echo_server.rs
42
-rw-r--r--
async-await/src/hyper.rs
29
-rw-r--r--
async-await/tests/macros.rs
22
-rw-r--r--
azure-pipelines.yml
184
-rw-r--r--
ci/azure-install-rust.yml
3
-rw-r--r--
ci/azure-rustfmt.yml
1
-rw-r--r--
ci/azure-test-stable.yml
25
-rw-r--r--
tokio-current-thread/Cargo.toml
4
-rw-r--r--
tokio-current-thread/src/lib.rs
111
-rw-r--r--
tokio-current-thread/src/scheduler.rs
170
-rw-r--r--
tokio-current-thread/tests/current_thread.rs
365
-rw-r--r--
tokio-executor/Cargo.toml
6
-rw-r--r--
tokio-executor/src/enter.rs
24
-rw-r--r--
tokio-executor/src/executor.rs
15
-rw-r--r--
tokio-executor/src/global.rs
33
-rw-r--r--
tokio-executor/src/park.rs
43
-rw-r--r--
tokio-executor/tests/enter.rs
18
-rw-r--r--
tokio-executor/tests/executor.rs
15
-rw-r--r--
tokio-futures/Cargo.toml
17
-rw-r--r--
tokio-futures/README.md
41
-rw-r--r--
tokio-futures/src/async_wait.rs
15
-rw-r--r--
tokio-futures/src/compat/backward.rs
86
-rw-r--r--
tokio-futures/src/compat/forward.rs
69
-rw-r--r--
tokio-futures/src/compat/mod.rs
42
-rw-r--r--
tokio-futures/src/future.rs
3
-rw-r--r--
tokio-futures/src/io/flush.rs
29
-rw-r--r--
tokio-futures/src/io/mod.rs
192
-rw-r--r--
tokio-futures/src/io/read.rs
32
-rw-r--r--
tokio-futures/src/io/read_exact.rs
50
-rw-r--r--
tokio-futures/src/io/write.rs
32
-rw-r--r--
tokio-futures/src/io/write_all.rs
51
-rw-r--r--
tokio-futures/src/lib.rs
32
-rw-r--r--
tokio-futures/src/macros.rs
12
-rw-r--r--
tokio-futures/src/sink.rs
68
-rw-r--r--
tokio-futures/src/sink/mod.rs
24
-rw-r--r--
tokio-futures/src/sink/send.rs
51
-rw-r--r--
tokio-futures/src/stream.rs
3
-rw-r--r--
tokio-futures/src/stream/mod.rs
38
-rw-r--r--
tokio-futures/src/stream/next.rs
28
-rw-r--r--
tokio-io/Cargo.toml
4
-rw-r--r--
tokio-io/src/_tokio_codec/decoder.rs
3
-rw-r--r--
tokio-io/src/_tokio_codec/encoder.rs
3
-rw-r--r--
tokio-io/src/_tokio_codec/framed.rs
281
-rw-r--r--
tokio-io/src/_tokio_codec/framed_read.rs
215
-rw-r--r--
tokio-io/src/_tokio_codec/framed_write.rs
245
-rw-r--r--
tokio-io/src/_tokio_codec/mod.rs
35
-rw-r--r--
tokio-io/src/allow_std.rs
93
-rw-r--r--
tokio-io/src/async_read.rs
122
-rw-r--r--
tokio-io/src/async_write.rs
132
-rw-r--r--
tokio-io/src/codec/bytes_codec.rs
42
-rw-r--r--
tokio-io/src/codec/decoder.rs
115
-rw-r--r--
tokio-io/src/codec/encoder.rs
25
-rw-r--r--
tokio-io/src/codec/lines_codec.rs
88
-rw-r--r--
tokio-io/src/codec/mod.rs
375
-rw-r--r--
tokio-io/src/framed.rs
246
-rw-r--r--
tokio-io/src/framed_read.rs
219
-rw-r--r--
tokio-io/src/framed_write.rs
249
-rw-r--r--
tokio-io/src/io/copy.rs
98
-rw-r--r--
tokio-io/src/io/flush.rs
41
-rw-r--r--
tokio-io/src/io/mod.rs
32
-rw-r--r--
tokio-io/src/io/read.rs
58
-rw-r--r--
tokio-io/src/io/read_exact.rs
83
-rw-r--r--
tokio-io/src/io/read_to_end.rs
64
-rw-r--r--
tokio-io/src/io/read_until.rs
74
-rw-r--r--
tokio-io/src/io/shutdown.rs
42
-rw-r--r--
tokio-io/src/io/write_all.rs
86
-rw-r--r--
tokio-io/src/length_delimited.rs
936
-rw-r--r--
tokio-io/src/lib.rs
44
-rw-r--r--
tokio-io/src/lines.rs
60
-rw-r--r--
tokio-io/src/split.rs
243
-rw-r--r--
tokio-io/src/window.rs
117
-rw-r--r--
tokio-io/tests/async_read.rs
180
-rw-r--r--
tokio-io/tests/length_delimited.rs
548
-rw-r--r--
tokio-macros/Cargo.toml
3
-rw-r--r--
tokio-macros/src/lib.rs
1
-rw-r--r--
tokio-reactor/Cargo.toml
3
-rw-r--r--
tokio-reactor/benches/basic.rs
2
-rw-r--r--
tokio-reactor/src/background.rs
214
-rw-r--r--
tokio-reactor/src/lib.rs
206
-rw-r--r--
tokio-reactor/src/poll_evented.rs
174
-rw-r--r--
tokio-reactor/src/registration.rs
100
-rw-r--r--
tokio-sync/Cargo.toml
14
-rw-r--r--
tokio-sync/src/lib.rs
13
-rw-r--r--
tokio-sync/src/lock.rs
14
-rw-r--r--
tokio-sync/src/loom.rs
3
-rw-r--r--
tokio-sync/src/mpsc/bounded.rs
65
-rw-r--r--
tokio-sync/src/mpsc/chan.rs
46
-rw-r--r--
tokio-sync/src/mpsc/unbounded.rs
44
-rw-r--r--
tokio-sync/src/oneshot.rs
90
-rw-r--r--
tokio-sync/src/semaphore.rs
73
-rw-r--r--
tokio-sync/src/task/atomic_task.rs
336
-rw-r--r--
tokio-sync/src/task/atomic_waker.rs
317
-rw-r--r--
tokio-sync/src/task/mod.rs
4
-rw-r--r--
tokio-sync/src/watch.rs
108
-rw-r--r--
tokio-sync/tests/atomic_task.rs
52
-rw-r--r--
tokio-sync/tests/atomic_waker.rs
37
-rw-r--r--
tokio-sync/tests/errors.rs
2
-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.rs
7
-rw-r--r--
tokio-sync/tests/fuzz_oneshot.rs
65
-rw-r--r--
tokio-sync/tests/fuzz_semaphore.rs
63
-rw-r--r--
tokio-sync/tests/lock.rs
73
-rw-r--r--
tokio-sync/tests/mpsc.rs
351
-rw-r--r--
tokio-sync/tests/oneshot.rs
160
-rw-r--r--
tokio-sync/tests/semaphore.rs
102
-rw-r--r--
tokio-sync/tests/watch.rs
195
-rw-r--r--
tokio-tcp/Cargo.toml
13
-rw-r--r--
tokio-tcp/src/incoming.rs
14
-rw-r--r--
tokio-tcp/src/lib.rs
16
-rw-r--r--
tokio-tcp/src/listener.rs
42
-rw-r--r--
tokio-tcp/src/stream.rs
175
-rw-r--r--
tokio-test/Cargo.toml
5
-rw-r--r--
tokio-test/src/lib.rs
6
-rw-r--r--
tokio-test/src/macros.rs
76
-rw-r--r--
tokio-test/src/task.rs
145
-rw-r--r--
tokio-timer/Cargo.toml
20
-rw-r--r--
tokio-timer/src/delay.rs
26
-rw-r--r--
tokio-timer/src/delay_queue.rs
56
-rw-r--r--
tokio-timer/src/interval.rs
15
-rw-r--r--
tokio-timer/src/lib.rs
19
-rw-r--r--
tokio-timer/src/throttle.rs
137
-rw-r--r--
tokio-timer/src/timeout.rs
178
-rw-r--r--
tokio-timer/src/timer/entry.rs
35
-rw-r--r--
tokio-timer/src/timer/handle.rs
12
-rw-r--r--
tokio-timer/src/timer/registration.rs
11