File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -17,8 +17,10 @@ internal class MessagingStream
17
17
private readonly AsyncDuplexStreamingCall < StreamingMessage , StreamingMessage > _call ;
18
18
private readonly SemaphoreSlim _semaphoreSlim = new SemaphoreSlim ( initialCount : 1 , maxCount : 1 ) ;
19
19
20
- internal MessagingStream ( string host , int port , int maxMessageLength )
20
+ internal MessagingStream ( string host , int port )
21
21
{
22
+ const int maxMessageLength = int . MaxValue ;
23
+
22
24
var channelOptions = new [ ]
23
25
{
24
26
new ChannelOption ( ChannelOptions . MaxReceiveMessageLength , maxMessageLength ) ,
Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ public async static Task Main(string[] args)
37
37
. WithParsed ( ops => arguments = ops )
38
38
. WithNotParsed ( err => Environment . Exit ( 1 ) ) ;
39
39
40
- var msgStream = new MessagingStream ( arguments . Host , arguments . Port , arguments . MaxMessageLength ) ;
40
+ var msgStream = new MessagingStream ( arguments . Host , arguments . Port ) ;
41
41
var requestProcessor = new RequestProcessor ( msgStream ) ;
42
42
43
43
// Send StartStream message
@@ -74,7 +74,7 @@ internal class WorkerArguments
74
74
[ Option ( "requestId" , Required = true , HelpText = "Request ID used for gRPC communication with the Host." ) ]
75
75
public string RequestId { get ; set ; }
76
76
77
- [ Option ( "grpcMaxMessageLength" , Required = true , HelpText = "gRPC Maximum message size." ) ]
77
+ [ Option ( "grpcMaxMessageLength" , Required = false , HelpText = "[Deprecated and ignored] gRPC Maximum message size." ) ]
78
78
public int MaxMessageLength { get ; set ; }
79
79
}
80
80
}
You can’t perform that action at this time.
0 commit comments