mirror of
https://github.com/OMGeeky/tarpc.git
synced 2026-01-23 03:18:49 +01:00
Do not ignore payload size in sync client (#194)
This commit is contained in:
@@ -106,7 +106,7 @@ impl Into<FutureOptions> for (reactor::Handle, Options) {
|
||||
#[cfg(feature = "tls")]
|
||||
fn into(self) -> FutureOptions {
|
||||
let (handle, options) = self;
|
||||
let mut opts = FutureOptions::default().handle(handle);
|
||||
let mut opts = FutureOptions::default().max_payload_size(options.max_payload_size).handle(handle);
|
||||
if let Some(tls_ctx) = options.tls_ctx {
|
||||
opts = opts.tls(tls_ctx);
|
||||
}
|
||||
@@ -115,8 +115,8 @@ impl Into<FutureOptions> for (reactor::Handle, Options) {
|
||||
|
||||
#[cfg(not(feature = "tls"))]
|
||||
fn into(self) -> FutureOptions {
|
||||
let (handle, _) = self;
|
||||
FutureOptions::default().handle(handle)
|
||||
let (handle, options) = self;
|
||||
FutureOptions::default().max_payload_size(options.max_payload_size).handle(handle)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user