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 @@ -35,7 +35,7 @@ public async static Task Main(string[] args)
35
35
. WithParsed ( ops => arguments = ops )
36
36
. WithNotParsed ( err => Environment . Exit ( 1 ) ) ;
37
37
38
- var msgStream = new MessagingStream ( arguments . Host , arguments . Port , arguments . MaxMessageLength ) ;
38
+ var msgStream = new MessagingStream ( arguments . Host , arguments . Port ) ;
39
39
var requestProcessor = new RequestProcessor ( msgStream ) ;
40
40
41
41
// Send StartStream message
@@ -63,7 +63,7 @@ internal class WorkerArguments
63
63
[ Option ( "requestId" , Required = true , HelpText = "Request ID used for gRPC communication with the Host." ) ]
64
64
public string RequestId { get ; set ; }
65
65
66
- [ Option ( "grpcMaxMessageLength" , Required = true , HelpText = "gRPC Maximum message size." ) ]
66
+ [ Option ( "grpcMaxMessageLength" , Required = false , HelpText = "[Deprecated and ignored] gRPC Maximum message size." ) ]
67
67
public int MaxMessageLength { get ; set ; }
68
68
}
69
69
}
You can’t perform that action at this time.
0 commit comments