Skip to content

Commit ec22b57

Browse files
refactor: remove unused maxInboundMessageCallOption method
1 parent 872a286 commit ec22b57

File tree

1 file changed

+0
-13
lines changed

1 file changed

+0
-13
lines changed

src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,8 @@
3737
import javax.annotation.Nonnull;
3838
import javax.annotation.Nullable;
3939

40-
import io.grpc.stub.AbstractStub;
4140
import io.netty.handler.codec.http.HttpMethod;
4241
import org.apache.arrow.flight.CallOption;
43-
import org.apache.arrow.flight.CallOptions;
4442
import org.apache.arrow.vector.FieldVector;
4543
import org.apache.arrow.vector.VectorSchemaRoot;
4644

@@ -355,17 +353,6 @@ private Stream<VectorSchemaRoot> queryData(@Nonnull final String query,
355353
);
356354
}
357355

358-
@Nonnull
359-
private CallOption maxInboundMessageCallOption() {
360-
return new CallOptions.GrpcCallOption() {
361-
@Override
362-
public <T extends AbstractStub<T>> T wrapStub(final T stub) {
363-
return stub.withMaxInboundMessageSize(Integer.MAX_VALUE);
364-
}
365-
};
366-
}
367-
368-
369356
@Nonnull
370357
private byte[] gzipData(@Nonnull final byte[] data) throws IOException {
371358
final ByteArrayOutputStream out = new ByteArrayOutputStream();

0 commit comments

Comments
 (0)