354 Commits

Author SHA1 Message Date
Aaron Turon
503f4a0405 Polish tokio-core in prep for overall 0.1 release
This commit makes a few tweaks to the new `easy` module:

- Rename `Parse` to `Decode`, and `Serialize` to `Encode`.

- Don't use `Poll` for the `decode` method; we prefer to reserve
  that type for actual aync events, and in particular for a `NotReady`
  result to imply that some task scheduling has taken place. Instead,
  use an internal `Option`.
2016-10-25 15:15:18 -07:00
Alex Crichton
623ce443d8 Add some warning comments 2016-10-24 20:03:27 -07:00
Alex Crichton
88fb0b32af Merge pull request #76 from spinda/into_inner
Add methods to extract inner from EasyFramed
2016-10-24 20:02:31 -07:00
Alex Crichton
bb22ef5f82 Merge pull request #78 from Archytaus/master
Fix typo in TcpStream and UdpSocket documentation
2016-10-24 19:22:59 -07:00
Ryan Scott
c9554fa174 Fixed a small typo of 'writey' where it was expected to be 'ready' in TcpStream and UdpSocket documentation. 2016-10-25 10:13:52 +09:00
Michael Smith
a1dfa14034
Add methods to extract inner from EasyFramed 2016-10-24 09:17:40 -07:00
Alex Crichton
37a2bed4cf Merge pull request #72 from dwrensha/copy-edit
Fix typo and awkward sentences.
2016-10-22 21:20:29 -07:00
David Renshaw
4a07828095 Fix typo and awkward sentences. 2016-10-23 11:14:52 +08:00
Alex Crichton
cefdb0c321 Merge pull request #71 from plietar/master
Allow start and end of window to match length of underlying slice.
2016-10-22 16:21:49 -07:00
Paul Lietar
4719fbdb28 Allow start and end of window to match length of underlying slice. 2016-10-22 15:56:02 +02:00
Alex Crichton
6d6c2aa390 Fix tests 2016-10-21 17:01:43 -07:00
Alex Crichton
2c5e4ebba8 Merge pull request #64 from alexcrichton/add-bytes
Move Framed from tokio-proto to core
2016-10-21 16:10:08 -07:00
Alex Crichton
b84ef90a98 Move Framed from tokio-proto to core
This commit extracts the concrete implementation of `FrameIo` in tokio-proto to
tokio-core under the name `EasyFramed`. This extraction is accompanied with a
new `EasyBuf` buffer type to work with when parsing types.

The purpose of this movement is to provide a clear and easy entry point at the
`FramedIo` layer for those who need it. Eventually these buffer types will get
replaced or moved to the `bytes` crate, but in the interest of an 0.1 release
and remaining backwards compatible with the tokio-core 0.1 release this is
adding a separate module.
2016-10-21 11:46:32 -07:00
Alex Crichton
3ced812993 Merge pull request #55 from oconnor663/read_once
rename Read to ReadOnce and expose it
2016-10-16 13:32:45 -07:00
Jack O'Connor
6789527952 rename ReadOnce back to Read, but keep it exposed 2016-10-15 09:46:59 -04:00
Alex Crichton
eecf3d129c Merge pull request #58 from oberien/master
fix(examples): Fix typos in chat example
2016-10-14 14:48:46 -07:00
oberien
7cf7833631 fix(examples): Fix typos in chat example
Rephrase a sentence to not contain the word `join` when we are actually using
`select` to prevent confusion.
2016-10-14 23:03:46 +02:00
Alex Crichton
bc2f857236 Touch up the chat example 2016-10-13 11:36:32 -07:00
Alex Crichton
688b67c8d8 Don't need regex from env_logger 2016-10-12 23:34:58 -07:00
Alex Crichton
227f454c52 Merge branch 'master' of https://github.com/oberien/tokio-core 2016-10-12 23:33:29 -07:00
oberien
315f601822 ref(examples): Minor refactoring in chat example
* Move connections-clone down a bit
* Use `Ok` and `Err` as IntoFuture
2016-10-11 20:08:13 +02:00
Alex Crichton
62514fc40b Merge pull request #52 from tailhook/intervals
Implement `tokio_core::reactor::Interval`
2016-10-10 08:00:22 -07:00
Paul Colomiets
b1d02eb598 Implement tokio_core::reactor::Interval 2016-10-10 15:41:57 +03:00
Jack O'Connor
da37ad0948 rename Read to ReadOnce and expose it
The other read futures (read_exact, read_until, etc.) all expose their
concrete future types so that function signatures can return them, but
until now `read()` didn't. Exposing it with the name "Read" causes
naming conflicts with the std::io::Read trait, so the easiest thing to
do is to just change the name. Importing std::io::Read under a different
name would've been an option too, but that would probably be annoying
for consumers in the same way it's annoying for us.

The original PR (https://github.com/tokio-rs/tokio-core/pull/29) decided
that "read" was a better name than "read_some", so I'm leaving the top
level functions unchanged. I don't have a strong opinion about it one
way or the other, but I *do* think it's worth bikeshedding a little bit.
Python's asyncio library actually ended up with a very similar issue
around naming inconsistency between the sync and async worlds, and we
can hopefully avoid repeating that: https://bugs.python.org/issue22279
2016-10-08 01:28:39 -04:00
oberien
b227738bd7 ref(chat): Make code more readable
* Send source address of message in addition to the message to connected clients.
* Move `spawn_fn` to the bottom.
* Use `map` instead of `and_then` if there is no need for blocking.
* `map` to unit where values are not needed anymore.
2016-10-07 14:57:30 +02:00
Paul Colomiets
411caa786d Moves when to Timeout from TimeoutToken 2016-10-06 21:11:46 +03:00
oberien
6961efa8dd fix(chat): Implement alexcrichton's suggestions
* Remove unnecessary clone
* Improve rightward drift
* Remove unnecessary lazy future
* Improve utf-8 handling
* Refactor to make code more understandable
2016-10-06 15:38:20 +02:00
Alex Crichton
a99b2529e0 Merge pull request #51 from debris/patch-1
fixed typo in split.rs
2016-10-05 09:03:02 -07:00
Marek Kotewicz
a94be1bca9 fixed typo in split.rs 2016-10-05 11:28:46 +02:00
oberien
0205b855d0 Add Chat example 2016-10-04 20:02:52 +02:00
Alex Crichton
e32115b1b4 Merge pull request #50 from oberien/read
doc(read): Add number of bytes read to doc
2016-10-04 07:50:44 -07:00
Alex Crichton
37879bd911 Merge pull request #49 from oberien/read_until
doc(read_until): Fix typo in doc
2016-10-04 07:46:36 -07:00
oberien
b0033eb463 doc(read): Add number of bytes read to doc 2016-10-04 13:56:31 +02:00
oberien
2545237309 doc(read_until): Fix typo in doc 2016-10-04 13:34:25 +02:00
Alex Crichton
f019f5f5bb Merge pull request #48 from oberien/read_until
feat(io): Add `read_until`
2016-10-03 09:34:11 -07:00
oberien
d2440a4059 fix(read_until): Make read_until resemble BufRead::read_until 2016-09-30 22:12:56 +02:00
oberien
ce8a9d460e feat(io): Add read_until 2016-09-30 22:06:43 +02:00
Alex Crichton
866dad2e85 Merge pull request #29 from 3Hren/master
Add `read` free function to read some bytes
2016-09-30 10:14:10 -07:00
Evgeny Safronov
f69f748470 chore: fix panic string 2016-09-30 13:20:22 +03:00
Evgeny Safronov
42bbe86cb6 refactor: rename ReadSome to Read
Also `try_nb!` is used.
2016-09-30 13:14:41 +03:00
Evgeny Safronov
4b3472ceae refactor: rename, also make EOF as a valid result 2016-09-29 12:19:20 +03:00
Alex Crichton
e92d4bf52b Merge pull request #47 from oberien/spawn_fn
doc(spawn_fn): Fix typo
2016-09-28 10:22:47 +09:00
oberien
f62d1ddc8d doc(spawn_fn): Fix typo 2016-09-28 03:20:33 +02:00
Alex Crichton
1d40bf14f7 Add Handle::spawn_fn
Acts as a convenience to avoid `futures::lazy`.

Closes #40
2016-09-26 16:52:54 -07:00
Alex Crichton
c2e80ebb30 Indiciate need_read requires poll_read
Original intention was that it didn't, but nowadays it does.

Closes #44
2016-09-26 16:27:29 -07:00
Alex Crichton
181dcdd9ea Merge pull request #39 from NeoLegends/patch-1
Fix documentation typos
2016-09-26 05:04:02 +09:00
Moritz Gunz
326537b861 Fix documentation typos 2016-09-21 18:27:25 +02:00
xenor
f41c55f9f7 Instead of calling handle() a second time in line 26, I used a reference to the value obtained in line 23. 2016-09-20 09:59:09 -07:00
Alex Crichton
418a973520 Add poll_{read,write} on halves
Closes #32
2016-09-14 11:14:18 -07:00
Evgeny Safronov
fb497aba44 Add read_some free function to read some bytes 2016-09-12 19:52:44 +03:00