diff --git a/src/Streaming.jl b/src/Streaming.jl index ec50c84..02779cf 100644 --- a/src/Streaming.jl +++ b/src/Streaming.jl @@ -162,7 +162,11 @@ test_response = grpc_async_await(client, req) """ function grpc_async_request( client::gRPCServiceClient{TRequest,true,TResponse,false}, - request::Channel{TRequest}, + request::Channel{TRequest}; + deadline=client.deadline, + keepalive=client.keepalive, + max_send_message_length=client.max_send_message_length, + max_recieve_message_length=client.max_recieve_message_length, ) where {TRequest<:Any,TResponse<:Any} req = gRPCRequest( @@ -172,10 +176,10 @@ function grpc_async_request( IOBuffer(), Channel{IOBuffer}(16), NOCHANNEL; - deadline = client.deadline, - keepalive = client.keepalive, - max_send_message_length = client.max_send_message_length, - max_recieve_message_length = client.max_recieve_message_length, + deadline=deadline, + keepalive=keepalive, + max_send_message_length=max_send_message_length, + max_recieve_message_length=max_recieve_message_length, ) request_task = Threads.@spawn grpc_async_stream_request(req, request) @@ -244,7 +248,11 @@ grpc_async_await(req) function grpc_async_request( client::gRPCServiceClient{TRequest,false,TResponse,true}, request::TRequest, - response::Channel{TResponse}, + response::Channel{TResponse}; + deadline=client.deadline, + keepalive=client.keepalive, + max_send_message_length=client.max_send_message_length, + max_recieve_message_length=client.max_recieve_message_length ) where {TRequest<:Any,TResponse<:Any} request_buf = grpc_encode_request_iobuffer( @@ -260,10 +268,10 @@ function grpc_async_request( IOBuffer(), NOCHANNEL, Channel{IOBuffer}(16); - deadline = client.deadline, - keepalive = client.keepalive, - max_send_message_length = client.max_send_message_length, - max_recieve_message_length = client.max_recieve_message_length, + deadline=deadline, + keepalive=keepalive, + max_send_message_length=max_send_message_length, + max_recieve_message_length=max_recieve_message_length, ) response_task = Threads.@spawn grpc_async_stream_response(req, response) @@ -344,7 +352,11 @@ grpc_async_await(req) function grpc_async_request( client::gRPCServiceClient{TRequest,true,TResponse,true}, request::Channel{TRequest}, - response::Channel{TResponse}, + response::Channel{TResponse}; + deadline=client.deadline, + keepalive=client.keepalive, + max_send_message_length=client.max_send_message_length, + max_recieve_message_length=client.max_recieve_message_length, ) where {TRequest<:Any,TResponse<:Any} req = gRPCRequest( @@ -354,10 +366,10 @@ function grpc_async_request( IOBuffer(), Channel{IOBuffer}(16), Channel{IOBuffer}(16); - deadline = client.deadline, - keepalive = client.keepalive, - max_send_message_length = client.max_send_message_length, - max_recieve_message_length = client.max_recieve_message_length, + deadline=deadline, + keepalive=keepalive, + max_send_message_length=max_send_message_length, + max_recieve_message_length=max_recieve_message_length, ) request_task = Threads.@spawn grpc_async_stream_request(req, request)