Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/grpc-web-it' into grpc-web-it
Browse files Browse the repository at this point in the history
  • Loading branch information
zZHorizonZz committed Jan 23, 2025
2 parents f4aa5c5 + e3002a9 commit 20fed56
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@
import io.vertx.core.buffer.Buffer;
import io.vertx.core.json.DecodeException;
import io.vertx.core.json.Json;
import io.vertx.core.json.JsonObject;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;

import java.nio.charset.StandardCharsets;
import java.util.function.Supplier;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,8 @@

import io.vertx.core.buffer.Buffer;
import io.vertx.core.internal.buffer.BufferInternal;
import io.vertx.grpc.common.WireFormat;
import io.vertx.grpc.common.GrpcMessage;
import io.vertx.grpc.common.WireFormat;

import java.util.Objects;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -256,6 +256,7 @@ private Future<Void> writeMessage(GrpcMessage message, boolean end) {
break;
}
}

sendHeaders(contentType, headers, end);
}
if (end) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@
*/
package io.vertx.grpc.common.impl;

import io.vertx.grpc.common.GrpcWriteStream;
import io.vertx.grpc.common.GrpcMessageEncoder;
import io.vertx.grpc.common.GrpcWriteStream;

/**
* An adapter between gRPC and Vert.x back-pressure.
Expand Down
1 change: 1 addition & 0 deletions vertx-grpc-common/src/main/java/module-info.java
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@
requires com.google.protobuf.util;
requires transitive io.vertx.core;
requires static io.vertx.codegen.api;
requires com.google.common;
exports io.vertx.grpc.common;
exports io.vertx.grpc.common.impl to io.vertx.tests.common, io.vertx.grpc.server, io.vertx.grpc.client, io.vertx.tests.server, io.vertx.tests.client;
provides VertxServiceProvider with io.vertx.grpc.common.impl.GrpcRequestLocalRegistration;
Expand Down
3 changes: 2 additions & 1 deletion vertx-grpc-common/src/test/java/module-info.java
Original file line number Diff line number Diff line change
Expand Up @@ -3,5 +3,6 @@
requires io.vertx.grpc.common;
requires io.vertx.testing.unit;
requires junit;
exports io.vertx.tests.common;
requires io.netty.codec.http;
exports io.vertx.tests.common;
}

0 comments on commit 20fed56

Please sign in to comment.