Skip to content

Commit

Permalink
WIP Formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
mhalbritter committed Feb 14, 2024
1 parent 57c00ca commit b1eb19e
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -112,11 +112,9 @@ void sendShouldSendSpansToZipkin() throws IOException, InterruptedException {
void sendShouldSendSpansToZipkinInProto3() throws IOException, InterruptedException {
mockBackEnd.enqueue(new MockResponse());
List<byte[]> encodedSpans = List.of(toByteArray("span1"), toByteArray("span2"));

try (BytesMessageSender sender = createSender(Encoding.PROTO3, Duration.ofSeconds(10))) {
sender.send(encodedSpans);
}

requestAssertions((request) -> {
assertThat(request.getMethod()).isEqualTo("POST");
assertThat(request.getHeader("Content-Type")).isEqualTo("application/x-protobuf");
Expand All @@ -132,7 +130,6 @@ void sendShouldSendSpansToZipkinInProto3() throws IOException, InterruptedExcept
void sendUsesDynamicEndpoint() throws Exception {
mockBackEnd.enqueue(new MockResponse());
mockBackEnd.enqueue(new MockResponse());

AtomicInteger suffix = new AtomicInteger();
try (BytesMessageSender sender = createSender((e) -> new HttpEndpointSupplier() {
@Override
Expand All @@ -147,7 +144,6 @@ public void close() {
sender.send(Collections.emptyList());
sender.send(Collections.emptyList());
}

assertThat(mockBackEnd.takeRequest().getPath()).endsWith("/1");
assertThat(mockBackEnd.takeRequest().getPath()).endsWith("/2");
}
Expand Down

0 comments on commit b1eb19e

Please sign in to comment.