| /tonic/tonic/src/transport/channel/service/ |
| H A D | io.rs | 5 use hyper::rt;
9 rt::Read + rt::Write + Send + 'static
13 impl<T> Io for T where T: rt::Read + rt::Write + Send + 'static {}
29 impl rt::Read for BoxedIo {
33 buf: rt::ReadBufCursor<'_>, in poll_read()
39 impl rt::Write for BoxedIo {
|
| H A D | connection.rs | 7 use hyper::rt;
8 use hyper::{client::conn::http2::Builder, rt::Executor};
9 use hyper_util::rt::TokioTimer;
33 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in new()
88 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in connect()
98 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in lazy()
179 C::Response: rt::Read + rt::Write + Unpin + Send,
|
| H A D | connector.rs | 11 use hyper::rt;
14 use hyper_util::rt::TokioIo;
36 C::Response: rt::Read + rt::Write + Unpin + Send + 'static,
|
| H A D | executor.rs | 2 use hyper_util::rt::TokioExecutor;
5 pub(crate) use hyper::rt::Executor;
|
| /tonic/examples/src/blocking/ |
| H A D | client.rs | 18 rt: Runtime, field
27 let rt = Builder::new_multi_thread().enable_all().build().unwrap(); in connect() localVariable
28 let client = rt.block_on(GreeterClient::connect(dst))?; in connect()
30 Ok(Self { client, rt }) in connect()
37 self.rt.block_on(self.client.say_hello(request)) in say_hello()
|
| H A D | server.rs | 35 let rt = Runtime::new().expect("failed to obtain a new RunTime object"); in main() localVariable
39 rt.block_on(server_future) in main()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | mod.rs | 29 use hyper::rt;
155 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in new()
176 C::Response: rt::Read + rt::Write + Unpin + Send + 'static, in connect()
|
| H A D | endpoint.rs | 10 use hyper::rt;
372 C::Response: rt::Read + rt::Write + Send + Unpin, in connect_with_connector()
397 C::Response: rt::Read + rt::Write + Send + Unpin, in connect_with_connector_lazy()
|
| /tonic/tests/default_stubs/ |
| H A D | Cargo.toml | 8 tokio = {version = "1.0", features = ["macros", "rt-multi-thread", "net"]}
|
| /tonic/examples/src/h2c/ |
| H A D | client.rs | 5 use hyper_util::rt::TokioExecutor;
40 rt::TokioExecutor,
|
| H A D | server.rs | 3 use hyper_util::rt::{TokioExecutor, TokioIo};
71 use hyper_util::{rt::TokioExecutor, service::TowerToHyperService};
|
| /tonic/tests/web/ |
| H A D | Cargo.toml | 15 tokio = { version = "1", features = ["macros", "rt", "net"] }
|
| /tonic/examples/src/grpc-web/ |
| H A D | client.rs | 2 use hyper_util::rt::TokioExecutor;
|
| /tonic/tests/compression/ |
| H A D | Cargo.toml | 17 tokio = {version = "1.0", features = ["macros", "rt-multi-thread", "net"]}
|
| /tonic/interop/ |
| H A D | Cargo.toml | 25 tokio = {version = "1.0", features = ["rt-multi-thread", "time", "macros"]}
|
| /tonic/examples/src/uds/ |
| H A D | client.rs | 8 use hyper_util::rt::TokioIo;
|
| /tonic/tests/integration_tests/ |
| H A D | Cargo.toml | 12 tokio = {version = "1.0", features = ["macros", "rt-multi-thread", "net", "sync"]}
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 16 let rt = tokio::runtime::Builder::new_multi_thread() localVariable
25 rt.block_on(async {
|
| /tonic/tonic-web/ |
| H A D | Cargo.toml | 31 tokio = { version = "1", features = ["macros", "rt"] }
|
| /tonic/tonic-health/ |
| H A D | Cargo.toml | 25 tokio = {version = "1.0", features = ["rt-multi-thread", "macros"]}
|
| /tonic/examples/src/tls_rustls/ |
| H A D | client.rs | 9 use hyper_util::{client::legacy::connect::HttpConnector, rt::TokioExecutor};
|
| H A D | server.rs | 7 rt::{TokioExecutor, TokioIo},
|
| /tonic/examples/src/mock/ |
| H A D | mock.rs | 1 use hyper_util::rt::TokioIo;
|
| /tonic/tonic-reflection/ |
| H A D | Cargo.toml | 32 tokio = { version = "1.0", features = ["sync", "rt"], optional = true }
|
| /tonic/tonic/ |
| H A D | Cargo.toml | 32 _tls-any = ["dep:tokio-rustls", "dep:tokio", "tokio?/rt", "tokio?/macros"] # Internal. Please choos…
107 tokio = {version = "1.0", features = ["rt", "macros"]}
|