OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-01 09:03:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Update to the latest rustc nightly.

Browse Source
This commit is contained in:
Tim Kuehn
2019-08-09 01:07:31 -07:00
parent 1cdff15412
commit d560ac6197
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
tarpc/examples/pubsub.rs
View File

@@ -4,7 +4,7 @@
// license that can be found in the LICENSE file or at
// https://opensource.org/licenses/MIT.
#![feature(async_await, existential_type)]
#![feature(async_await, type_alias_impl_trait)]
use futures::{
future::{self, Ready},
@@ -12,7 +12,7 @@ use futures::{
Future,
};
use publisher::Publisher as _;
use rpc::{
use tarpc::{
client, context,
server::{self, Handler},
};
@@ -87,7 +87,7 @@ impl Publisher {
}
impl publisher::Publisher for Publisher {
existential type BroadcastFut: Future<Output = ()>;
type BroadcastFut = impl Future<Output = ()>;
fn broadcast(self, _: context::Context, message: String) -> Self::BroadcastFut {
async fn broadcast(
@@ -106,7 +106,7 @@ impl publisher::Publisher for Publisher {
broadcast(self.clients.clone(), message)
}
existential type SubscribeFut: Future<Output = Result<(), String>>;
type SubscribeFut = impl Future<Output = Result<(), String>>;
fn subscribe(self, _: context::Context, id: u32, addr: SocketAddr) -> Self::SubscribeFut {
async fn subscribe(
@@ -125,7 +125,7 @@ impl publisher::Publisher for Publisher {
subscribe(Arc::clone(&self.clients), id, addr).map_err(|e| e.to_string())
}
existential type UnsubscribeFut: Future<Output = ()>;
type UnsubscribeFut = impl Future<Output = ()>;
fn unsubscribe(self, _: context::Context, id: u32) -> Self::UnsubscribeFut {
eprintln!("Unsubscribing {}", id);

2
tarpc/examples/readme.rs
View File

@@ -10,7 +10,7 @@ use futures::{
future::{self, Ready},
prelude::*,
};
use rpc::{
use tarpc::{
client, context,
server::{BaseChannel, Channel},
};

6
tarpc/examples/server_calling_server.rs
View File

@@ -4,14 +4,14 @@
// license that can be found in the LICENSE file or at
// https://opensource.org/licenses/MIT.
#![feature(existential_type, async_await)]
#![feature(async_await, type_alias_impl_trait)]
use crate::{add::Add as AddService, double::Double as DoubleService};
use futures::{
future::{self, Ready},
prelude::*,
};
use rpc::{
use tarpc::{
client, context,
server::{Handler, Server},
};
@@ -50,7 +50,7 @@ struct DoubleServer {
}
impl DoubleService for DoubleServer {
existential type DoubleFut: Future<Output = Result<i32, String>> + Send;
type DoubleFut = impl Future<Output = Result<i32, String>> + Send;
fn double(self, _: context::Context, x: i32) -> Self::DoubleFut {
async fn double(mut client: add::AddClient, x: i32) -> Result<i32, String> {