OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2025-12-31 00:21:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

No longer fully qualify my_server::*

Browse Source
This commit is contained in:
Adam Wright
2016-01-08 03:22:58 -08:00
parent ba254a8b96
commit d13aa62f51
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/macros/src/lib.rs
View File

@@ -96,20 +96,19 @@ macro_rules! rpc_service {
mod test {
use std::net::{TcpListener, TcpStream};
use std::thread;
#[derive(PartialEq, Debug, RustcEncodable, RustcDecodable)]
pub struct Foo {
message: String
}
use self::my_server::*;
rpc_service!(my_server:
hello(super::Foo) -> super::Foo;
add((i32, i32)) -> i32;
);
//use my_server::*;
#[derive(PartialEq, Debug, RustcEncodable, RustcDecodable)]
pub struct Foo {
message: String
}
impl my_server::Service for () {
impl Service for () {
fn hello(&self, s: Foo) -> Foo {
Foo{message: format!("Hello, {}", &s.message)}
}
@@ -124,11 +123,11 @@ mod test {
println!("Starting");
let listener = TcpListener::bind("127.0.0.1:9000").unwrap();
thread::spawn(|| {
let server = my_server::Server::new(());
let server = Server::new(());
println!("Server running");
server.serve(listener);
});
let mut client = my_server::Client(TcpStream::connect("127.0.0.1:9000").unwrap());
let mut client = Client(TcpStream::connect("127.0.0.1:9000").unwrap());
assert_eq!(3, client.add((1, 2)).unwrap());
let foo = Foo{message: "Adam".into()};
let want = Foo{message: format!("Hello, {}", &foo.message)};