Skip to content

Commit

Permalink
track renamed types in tower-rs/tower-h2@f915f56
Browse files Browse the repository at this point in the history
Signed-off-by: Eliza Weisman <eliza@buoyant.io>
  • Loading branch information
hawkw committed Jan 12, 2018
1 parent 4d800b7 commit 8213b92
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
6 changes: 3 additions & 3 deletions proxy/src/bind.rs
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ pub struct Bind<C, B> {

type Service<B> = Reconnect<
telemetry::sensor::NewHttp<
tower_h2::client::Client<
tower_h2::client::Connect<
telemetry::sensor::Connect<transport::TimeoutConnect<transport::Connect>>,
CtxtExec,
B,
Expand Down Expand Up @@ -140,15 +140,15 @@ where
let connect = {
let c = Timeout::new(
transport::Connect::new(*addr, &self.executor),
self.connect_timeout,
self.connect_timeout,
&self.executor,
);

self.sensors.connect(c, &client_ctx)
};

// Establishes an HTTP/2.0 connection
let client = tower_h2::client::Client::new(
let client = tower_h2::client::Connect::new(
connect,
self.h2_builder.clone(),
::logging::context_executor(("client", *addr), self.executor.clone()),
Expand Down
2 changes: 1 addition & 1 deletion proxy/src/control/codec.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ use std::marker::PhantomData;

use bytes::{Buf, BufMut};
use prost::{DecodeError, Message};
use tower_grpc::client::codec::{Codec, DecodeBuf, EncodeBuf};
use tower_grpc::codec::{Codec, DecodeBuf, EncodeBuf};

/// A protobuf codec.
pub struct Protobuf<T, U>(PhantomData<(T, U)>);
Expand Down
2 changes: 1 addition & 1 deletion proxy/src/inbound.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ pub struct Inbound<B> {
bind: Bind<B>,
}

type Client<B> = tower_h2::client::Client<
type Client<B> = tower_h2::client::Connect<
telemetry::sensor::Connect<transport::TimeoutConnect<transport::Connect>>,
CtxtExec,
B,
Expand Down

0 comments on commit 8213b92

Please sign in to comment.