mirror of
https://github.com/OMGeeky/tarpc.git
synced 2026-02-23 15:49:54 +01:00
Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
05a924d27f | ||
|
|
af9d71ed0d |
@@ -33,7 +33,7 @@ arguments to tarpc fns.
|
|||||||
Add to your `Cargo.toml` dependencies:
|
Add to your `Cargo.toml` dependencies:
|
||||||
|
|
||||||
```toml
|
```toml
|
||||||
tarpc = "0.15.0"
|
tarpc = "0.17.0"
|
||||||
```
|
```
|
||||||
|
|
||||||
The `service!` macro expands to a collection of items that form an
|
The `service!` macro expands to a collection of items that form an
|
||||||
@@ -48,7 +48,7 @@ races!
|
|||||||
Here's a small service.
|
Here's a small service.
|
||||||
|
|
||||||
```rust
|
```rust
|
||||||
#![feature(futures_api, pin, arbitrary_self_types, await_macro, async_await, proc_macro_hygiene)]
|
#![feature(pin, arbitrary_self_types, await_macro, async_await, proc_macro_hygiene)]
|
||||||
|
|
||||||
|
|
||||||
use futures::{
|
use futures::{
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "tarpc-bincode-transport"
|
name = "tarpc-bincode-transport"
|
||||||
version = "0.5.0"
|
version = "0.6.0"
|
||||||
authors = ["Tim Kuehn <tikue@google.com>"]
|
authors = ["Tim Kuehn <tikue@google.com>"]
|
||||||
edition = '2018'
|
edition = '2018'
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
@@ -14,10 +14,10 @@ description = "A bincode-based transport for tarpc services."
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
bincode = "1"
|
bincode = "1"
|
||||||
futures-preview = { version = "0.3.0-alpha.14", features = ["compat"] }
|
futures-preview = { version = "0.3.0-alpha.15", features = ["compat"] }
|
||||||
futures_legacy = { version = "0.1", package = "futures" }
|
futures_legacy = { version = "0.1", package = "futures" }
|
||||||
pin-utils = "0.1.0-alpha.4"
|
pin-utils = "0.1.0-alpha.4"
|
||||||
rpc = { package = "tarpc-lib", version = "0.4", path = "../rpc", features = ["serde1"] }
|
rpc = { package = "tarpc-lib", version = "0.5", path = "../rpc", features = ["serde1"] }
|
||||||
serde = "1.0"
|
serde = "1.0"
|
||||||
tokio-io = "0.1"
|
tokio-io = "0.1"
|
||||||
async-bincode = "0.4"
|
async-bincode = "0.4"
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
//! A TCP [`Transport`] that serializes as bincode.
|
//! A TCP [`Transport`] that serializes as bincode.
|
||||||
|
|
||||||
#![feature(futures_api, arbitrary_self_types, await_macro, async_await)]
|
#![feature(arbitrary_self_types, await_macro, async_await)]
|
||||||
#![deny(missing_docs, missing_debug_implementations)]
|
#![deny(missing_docs, missing_debug_implementations)]
|
||||||
|
|
||||||
use async_bincode::{AsyncBincodeStream, AsyncDestination};
|
use async_bincode::{AsyncBincodeStream, AsyncDestination};
|
||||||
|
|||||||
@@ -9,7 +9,6 @@
|
|||||||
#![feature(
|
#![feature(
|
||||||
test,
|
test,
|
||||||
integer_atomics,
|
integer_atomics,
|
||||||
futures_api,
|
|
||||||
generators,
|
generators,
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await
|
async_await
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
//! Tests client/server control flow.
|
//! Tests client/server control flow.
|
||||||
|
|
||||||
#![feature(generators, await_macro, async_await, futures_api)]
|
#![feature(generators, await_macro, async_await)]
|
||||||
|
|
||||||
use futures::{
|
use futures::{
|
||||||
compat::{Executor01CompatExt, Future01CompatExt},
|
compat::{Executor01CompatExt, Future01CompatExt},
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
//! Tests client/server control flow.
|
//! Tests client/server control flow.
|
||||||
|
|
||||||
#![feature(generators, await_macro, async_await, futures_api)]
|
#![feature(generators, await_macro, async_await)]
|
||||||
|
|
||||||
use futures::{
|
use futures::{
|
||||||
compat::{Executor01CompatExt, Future01CompatExt},
|
compat::{Executor01CompatExt, Future01CompatExt},
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "tarpc-example-service"
|
name = "tarpc-example-service"
|
||||||
version = "0.4.0"
|
version = "0.5.0"
|
||||||
authors = ["Tim Kuehn <tikue@google.com>"]
|
authors = ["Tim Kuehn <tikue@google.com>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
@@ -13,11 +13,11 @@ readme = "../README.md"
|
|||||||
description = "An example server built on tarpc."
|
description = "An example server built on tarpc."
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
bincode-transport = { package = "tarpc-bincode-transport", version = "0.5", path = "../bincode-transport" }
|
bincode-transport = { package = "tarpc-bincode-transport", version = "0.6", path = "../bincode-transport" }
|
||||||
clap = "2.0"
|
clap = "2.0"
|
||||||
futures-preview = { version = "0.3.0-alpha.14", features = ["compat"] }
|
futures-preview = { version = "0.3.0-alpha.15", features = ["compat"] }
|
||||||
serde = { version = "1.0" }
|
serde = { version = "1.0" }
|
||||||
tarpc = { version = "0.16", path = "../tarpc", features = ["serde1"] }
|
tarpc = { version = "0.17", path = "../tarpc", features = ["serde1"] }
|
||||||
tokio = "0.1"
|
tokio = "0.1"
|
||||||
tokio-executor = "0.1"
|
tokio-executor = "0.1"
|
||||||
|
|
||||||
|
|||||||
@@ -4,7 +4,7 @@
|
|||||||
// license that can be found in the LICENSE file or at
|
// license that can be found in the LICENSE file or at
|
||||||
// https://opensource.org/licenses/MIT.
|
// https://opensource.org/licenses/MIT.
|
||||||
|
|
||||||
#![feature(futures_api, arbitrary_self_types, await_macro, async_await)]
|
#![feature(arbitrary_self_types, await_macro, async_await)]
|
||||||
|
|
||||||
use clap::{App, Arg};
|
use clap::{App, Arg};
|
||||||
use futures::{compat::Executor01CompatExt, prelude::*};
|
use futures::{compat::Executor01CompatExt, prelude::*};
|
||||||
|
|||||||
@@ -5,7 +5,6 @@
|
|||||||
// https://opensource.org/licenses/MIT.
|
// https://opensource.org/licenses/MIT.
|
||||||
|
|
||||||
#![feature(
|
#![feature(
|
||||||
futures_api,
|
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await,
|
async_await,
|
||||||
|
|||||||
@@ -4,7 +4,7 @@
|
|||||||
// license that can be found in the LICENSE file or at
|
// license that can be found in the LICENSE file or at
|
||||||
// https://opensource.org/licenses/MIT.
|
// https://opensource.org/licenses/MIT.
|
||||||
|
|
||||||
#![feature(futures_api, arbitrary_self_types, await_macro, async_await)]
|
#![feature(arbitrary_self_types, await_macro, async_await)]
|
||||||
|
|
||||||
use clap::{App, Arg};
|
use clap::{App, Arg};
|
||||||
use futures::{
|
use futures::{
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "tarpc-lib"
|
name = "tarpc-lib"
|
||||||
version = "0.4.0"
|
version = "0.5.0"
|
||||||
authors = ["Tim Kuehn <tikue@google.com>"]
|
authors = ["Tim Kuehn <tikue@google.com>"]
|
||||||
edition = '2018'
|
edition = '2018'
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
@@ -18,7 +18,7 @@ serde1 = ["trace/serde", "serde", "serde/derive"]
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
fnv = "1.0"
|
fnv = "1.0"
|
||||||
futures-preview = { version = "0.3.0-alpha.14", features = ["compat"] }
|
futures-preview = { version = "0.3.0-alpha.15", features = ["compat"] }
|
||||||
humantime = "1.0"
|
humantime = "1.0"
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
pin-utils = "0.1.0-alpha.4"
|
pin-utils = "0.1.0-alpha.4"
|
||||||
@@ -28,6 +28,6 @@ trace = { package = "tarpc-trace", version = "0.2", path = "../trace" }
|
|||||||
serde = { optional = true, version = "1.0" }
|
serde = { optional = true, version = "1.0" }
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
futures-test-preview = { version = "0.3.0-alpha.14" }
|
futures-test-preview = { version = "0.3.0-alpha.15" }
|
||||||
env_logger = "0.6"
|
env_logger = "0.6"
|
||||||
tokio = "0.1"
|
tokio = "0.1"
|
||||||
|
|||||||
@@ -8,7 +8,6 @@
|
|||||||
non_exhaustive,
|
non_exhaustive,
|
||||||
integer_atomics,
|
integer_atomics,
|
||||||
try_trait,
|
try_trait,
|
||||||
futures_api,
|
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await
|
async_await
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "tarpc"
|
name = "tarpc"
|
||||||
version = "0.16.0"
|
version = "0.17.0"
|
||||||
authors = ["Adam Wright <adam.austin.wright@gmail.com>", "Tim Kuehn <timothy.j.kuehn@gmail.com>"]
|
authors = ["Adam Wright <adam.austin.wright@gmail.com>", "Tim Kuehn <timothy.j.kuehn@gmail.com>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
@@ -19,17 +19,17 @@ serde1 = ["rpc/serde1", "serde", "serde/derive"]
|
|||||||
travis-ci = { repository = "google/tarpc" }
|
travis-ci = { repository = "google/tarpc" }
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
futures-preview = { version = "0.3.0-alpha.14", features = ["compat"] }
|
futures-preview = { version = "0.3.0-alpha.15", features = ["compat"] }
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
serde = { optional = true, version = "1.0" }
|
serde = { optional = true, version = "1.0" }
|
||||||
rpc = { package = "tarpc-lib", path = "../rpc", version = "0.4" }
|
rpc = { package = "tarpc-lib", path = "../rpc", version = "0.5" }
|
||||||
tarpc-plugins = { path = "../plugins", version = "0.5.0" }
|
tarpc-plugins = { path = "../plugins", version = "0.5.0" }
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
bincode = "1"
|
bincode = "1"
|
||||||
bytes = { version = "0.4", features = ["serde"] }
|
bytes = { version = "0.4", features = ["serde"] }
|
||||||
humantime = "1.0"
|
humantime = "1.0"
|
||||||
bincode-transport = { package = "tarpc-bincode-transport", version = "0.5", path = "../bincode-transport" }
|
bincode-transport = { package = "tarpc-bincode-transport", version = "0.6", path = "../bincode-transport" }
|
||||||
env_logger = "0.6"
|
env_logger = "0.6"
|
||||||
libtest = "0.0.1"
|
libtest = "0.0.1"
|
||||||
tokio = "0.1"
|
tokio = "0.1"
|
||||||
|
|||||||
@@ -6,7 +6,6 @@
|
|||||||
|
|
||||||
#![feature(
|
#![feature(
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
futures_api,
|
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await,
|
async_await,
|
||||||
existential_type,
|
existential_type,
|
||||||
|
|||||||
@@ -5,7 +5,6 @@
|
|||||||
// https://opensource.org/licenses/MIT.
|
// https://opensource.org/licenses/MIT.
|
||||||
|
|
||||||
#![feature(
|
#![feature(
|
||||||
futures_api,
|
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await,
|
async_await,
|
||||||
|
|||||||
@@ -7,7 +7,6 @@
|
|||||||
#![feature(
|
#![feature(
|
||||||
existential_type,
|
existential_type,
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
futures_api,
|
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await,
|
async_await,
|
||||||
proc_macro_hygiene
|
proc_macro_hygiene
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
#![feature(
|
#![feature(
|
||||||
async_await,
|
async_await,
|
||||||
await_macro,
|
await_macro,
|
||||||
futures_api,
|
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
proc_macro_hygiene,
|
proc_macro_hygiene,
|
||||||
impl_trait_in_bindings
|
impl_trait_in_bindings
|
||||||
|
|||||||
@@ -9,7 +9,7 @@
|
|||||||
#![feature(async_await, external_doc)]
|
#![feature(async_await, external_doc)]
|
||||||
#![cfg_attr(
|
#![cfg_attr(
|
||||||
test,
|
test,
|
||||||
feature(futures_api, await_macro, proc_macro_hygiene, arbitrary_self_types)
|
feature(await_macro, proc_macro_hygiene, arbitrary_self_types)
|
||||||
)]
|
)]
|
||||||
|
|
||||||
#[doc(hidden)]
|
#[doc(hidden)]
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ macro_rules! add_serde_if_enabled {
|
|||||||
/// Rpc methods are specified, mirroring trait syntax:
|
/// Rpc methods are specified, mirroring trait syntax:
|
||||||
///
|
///
|
||||||
/// ```
|
/// ```
|
||||||
/// # #![feature(await_macro, pin, arbitrary_self_types, async_await, futures_api, proc_macro_hygiene)]
|
/// # #![feature(await_macro, pin, arbitrary_self_types, async_await, proc_macro_hygiene)]
|
||||||
/// # fn main() {}
|
/// # fn main() {}
|
||||||
/// # tarpc::service! {
|
/// # tarpc::service! {
|
||||||
/// /// Say hello
|
/// /// Say hello
|
||||||
|
|||||||
@@ -8,7 +8,6 @@
|
|||||||
test,
|
test,
|
||||||
arbitrary_self_types,
|
arbitrary_self_types,
|
||||||
integer_atomics,
|
integer_atomics,
|
||||||
futures_api,
|
|
||||||
generators,
|
generators,
|
||||||
await_macro,
|
await_macro,
|
||||||
async_await,
|
async_await,
|
||||||
|
|||||||
Reference in New Issue
Block a user