fix: reassign stub after applying grpcMaxMessageSize

bevzzz · bevzzz · commit 10508562273a · 2025-11-17T15:26:38.000+01:00
diff --git a/src/main/java/io/weaviate/client6/v1/internal/grpc/DefaultGrpcTransport.java b/src/main/java/io/weaviate/client6/v1/internal/grpc/DefaultGrpcTransport.java
@@ -43,8 +43,8 @@ public DefaultGrpcTransport(GrpcChannelOptions transportOptions) {
 
     if (transportOptions.maxMessageSize() != null) {
       var max = transportOptions.maxMessageSize();
-      blockingStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);
-      futureStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);
+      blockingStub = blockingStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);
+      futureStub = futureStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);
     }
 
     if (transportOptions.tokenProvider() != null) {

Original file line number	Diff line number	Diff line change
`@@ -43,8 +43,8 @@ public DefaultGrpcTransport(GrpcChannelOptions transportOptions) {`
`43`	`43`
`44`	`44`	`if (transportOptions.maxMessageSize() != null) {`
`45`	`45`	`var max = transportOptions.maxMessageSize();`
`46`		`- blockingStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);`
`47`		`- futureStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);`
	`46`	`+ blockingStub = blockingStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);`
	`47`	`+ futureStub = futureStub.withMaxInboundMessageSize(max).withMaxOutboundMessageSize(max);`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`if (transportOptions.tokenProvider() != null) {`