Tim Kuehn
802ee838ca
Don't reexport client implementation details from crate root.
2017-01-17 16:38:30 -08:00
Tim Kuehn
cabbbb2a0b
Fix some doc comments and remove unused impl.
2017-01-15 17:00:04 -08:00
Tim Kuehn
a8e5bc45a1
Minor refactor
2017-01-12 00:31:46 -08:00
Tim Kuehn
95c57a4b2d
Add Options to all connect and listen fns
2017-01-12 00:06:17 -08:00
Tim Kuehn
05c6be192d
Rework the future Connect trait to only have one method, which takes an Options arg.
2017-01-11 22:55:04 -08:00
Tim Kuehn
918b6b3b75
Make spawn_core private
2017-01-11 20:44:59 -08:00
Tim Kuehn
a660ed7f1a
Remove unnecessary trait
2017-01-11 20:27:17 -08:00
Tim Kuehn
3eb2292841
Remove unused code
2017-01-11 20:22:52 -08:00
Tim Kuehn
e4ef0881e6
Update Cargo.toml to use crates.io releases of tokio deps.
2017-01-11 14:23:52 -08:00
Tim Kuehn
ffea090726
Make SyncClient only require &self for RPCs.
2017-01-08 22:13:49 -08:00
Tim Kuehn
e8f942f463
Merge master into tokio-tracking.
2017-01-08 22:05:10 -08:00
Adam Wright
48452c04a6
Remove unecessary unreachable! calls ( #8 )
2017-01-08 20:36:28 -08:00
Tim Kuehn
3719564efc
Fix stale comment
2017-01-08 17:38:05 -08:00
Tim Kuehn
ef41d4349c
Make connection backlog arg to listen a const
2017-01-08 17:34:44 -08:00
Tim Kuehn
200407a4c9
Make connection backlog arg to listen a const
2017-01-08 17:30:31 -08:00
Tim Kuehn
5dbfa99d0b
Shuffle around the sync/future modules
2016-12-26 16:02:44 -05:00
Tim Kuehn
18cbbe5b15
impl Clone (again) for the clients
2016-12-26 15:30:36 -05:00
Tim Kuehn
e22210bfd8
Rename module framed -> protocol, and clarify some type parameters.
2016-12-26 14:54:31 -05:00
Tim Kuehn
d242bdbb82
Track latest tokio changes
2016-12-26 00:27:42 -05:00
Tim Kuehn
bdd6737914
Add a test for concurrent requests
2016-12-16 14:22:25 -08:00
Tim Kuehn
f2bf1adf8b
Fix bug wherein the Codec was clearing the buf after decoding a message. Don't do thatgit stash pop!
2016-12-16 14:15:31 -08:00
Tim Kuehn
35f8aefb30
Small refactor
2016-12-11 16:43:41 -08:00
Tim Kuehn
5c17ffacae
Add listen_with fns.
2016-12-05 15:23:43 -08:00
Tim Kuehn
13e56481bb
Track latest changes to tokio-proto.
2016-12-04 20:26:32 -08:00
Tim Kuehn
d47a931f9f
Elaborate in the doc comment for Framed
2016-11-05 16:33:41 -07:00
Tim Kuehn
a30e929b63
Clarify some docs and fix some dumb code.
2016-11-05 15:43:31 -07:00
Tim Kuehn
b638f45d27
Add a method to util::FirstSocketAddr that returns a Result rather than panicking
2016-11-05 15:43:09 -07:00
Tim Kuehn
3afcfe6274
Track latest git deps and rust compiler
2016-11-05 15:06:39 -07:00
Tim Kuehn
aaaaf942d6
Add future::Connect::connect_remotely.
2016-10-29 10:15:39 -07:00
Tim Kuehn
29b6425fb5
Add a util fn for running a reactor forever on a new thread.
2016-10-29 10:15:15 -07:00
Tim Kuehn
539776eb27
Make future::Connect take a lifetime param so that connect_with doesn't have to clone Handle.
2016-10-29 09:38:43 -07:00
Tim Kuehn
b6e9d61286
Add futures::Connect::connect_with, allowing the user to specify the reactor core to use.
2016-10-29 02:01:40 -07:00
Tim Kuehn
67ad2b90be
Track nightly compiler
2016-10-28 16:13:59 -07:00
Tim Kuehn
3506397150
Track latest tokio changes.
2016-10-28 11:33:20 -07:00
Tim Kuehn
db665ebb60
Bump itertools from 0.4 => 0.5
2016-10-27 19:07:54 -07:00
Tim Kuehn
cff8782e18
Replace try! with ?
2016-10-16 13:49:53 -07:00
Tim Kuehn
531dc20d66
Track nightly
2016-10-16 13:19:35 -07:00
Adam Wright
d8d240ec12
Add docs to play nicer with deny(misisng_docs) ( #6 )
2016-10-10 12:25:28 -04:00
Tim Kuehn
b661ff0175
Complete ClientFuture on error.
2016-09-30 15:36:55 -04:00
Tim Kuehn
b880d65f44
Merge branch 'framed' of github.com:tikue/tarpc into framed
2016-09-30 15:19:16 -04:00
Tim Kuehn
451b99b92a
Remove all remaining #[inline]s.
2016-09-30 15:16:29 -04:00
Tim Kuehn
99b13ae6fc
Remove an unnecessary Box
2016-09-28 00:04:58 -07:00
Tim Kuehn
5bace01f2b
Finish the multiplex implementation
2016-09-26 23:44:22 -07:00
Tim Kuehn
4a63064cbd
Remove some panics, and don't use ToSocketAddrs in async methods.
2016-09-19 00:16:47 -07:00
Tim Kuehn
3eb57d4009
Move the static remote to the default reactor core to the crate root.
...
It didn't really make sense in the framed module, which doesn't care about such things.
2016-09-17 18:31:08 -07:00
Tim Kuehn
14c97b61f9
Rename things to align with tokio changes.
2016-09-17 18:23:35 -07:00
Tim Kuehn
20d1a019ae
WIP multiplex Parse/Serialize/FramedIo impls
2016-09-17 12:50:48 -07:00
Tim Kuehn
8c0181633d
Track crates.io deps
2016-09-14 10:11:28 -07:00
Tim Kuehn
1c318182c4
Don't serialize on a thread pool
2016-09-14 01:54:03 -07:00
Tim
e8902c21a2
Mangle a lot of names in macro expansion. ( #53 )
...
* Mangle a lot of names in macro expansion.
To lower the chance of any issues, prefix idents in service expansion with __tarpc_service.
In future_enum, prefix with __future_enum. The pattern is basically __macro_name_ident.
Any imported enum variant will conflict with a let binding or a function arg, so we basically
can't use any generic idents at all. Example:
enum Req { request(..) }
use self::Req::request;
fn make_request(request: Request) { ... }
^^^^^^^ conflict here
Additionally, suffix generated associated types with Fut to avoid conflicts with camelcased rpcs.
Why someone would do that, I don't know, but we shouldn't allow that wart.
* Trim long macro lines
2016-09-14 01:34:35 -07:00