Expose builder
This commit is contained in:
@@ -1,6 +1,6 @@
|
|||||||
use tokio::net::TcpListener;
|
use tokio::net::TcpListener;
|
||||||
use tonic::{Code, Request, Response, Status};
|
use tonic::{Code, Request, Response, Status};
|
||||||
use tower_h2::Server;
|
use tower_h2::{Server, Builder};
|
||||||
|
|
||||||
pub mod pb {
|
pub mod pb {
|
||||||
#![allow(dead_code)]
|
#![allow(dead_code)]
|
||||||
@@ -62,6 +62,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
let mut bind = TcpListener::bind(&addr)?;
|
let mut bind = TcpListener::bind(&addr)?;
|
||||||
|
|
||||||
let greeter = TestService::default();
|
let greeter = TestService::default();
|
||||||
|
let mut settings = Builder::default();
|
||||||
|
settings.initial_connection_window_size(1_000_000_000);
|
||||||
let mut server = Server::new(TestServiceServer::new(greeter), Default::default());
|
let mut server = Server::new(TestServiceServer::new(greeter), Default::default());
|
||||||
|
|
||||||
while let Ok((sock, _addr)) = bind.accept().await {
|
while let Ok((sock, _addr)) = bind.accept().await {
|
||||||
|
|||||||
+1
-1
@@ -12,4 +12,4 @@ mod server;
|
|||||||
|
|
||||||
pub use client::Connection;
|
pub use client::Connection;
|
||||||
pub use recv_body::RecvBody;
|
pub use recv_body::RecvBody;
|
||||||
pub use server::Server;
|
pub use server::{Builder, Server};
|
||||||
|
|||||||
@@ -7,6 +7,8 @@ use tokio_io::{AsyncRead, AsyncWrite};
|
|||||||
use tower_service::Service;
|
use tower_service::Service;
|
||||||
use tower_util::MakeService;
|
use tower_util::MakeService;
|
||||||
|
|
||||||
|
pub use h2::server::Builder;
|
||||||
|
|
||||||
pub struct Server<M, B>
|
pub struct Server<M, B>
|
||||||
where
|
where
|
||||||
M: MakeService<(), Request<RecvBody>>,
|
M: MakeService<(), Request<RecvBody>>,
|
||||||
|
|||||||
Reference in New Issue
Block a user