Skip to content

Commit 39f0b3e

Browse files
addressing comments
Signed-off-by: Anthony Petrov <anthony@swirldslabs.com>
1 parent b802aee commit 39f0b3e

1 file changed

Lines changed: 13 additions & 11 deletions

File tree

  • pbj-integration-tests/src/jmh/java/com/hedera/pbj/integration/jmh/grpc

pbj-integration-tests/src/jmh/java/com/hedera/pbj/integration/jmh/grpc/PbjGrpcBench.java

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -116,19 +116,19 @@ public void tearDown() {
116116
try {
117117
client.close();
118118
} catch (Exception ex) {
119-
new RuntimeException(ex).printStackTrace();
119+
ex.printStackTrace();
120120
}
121121
client = null;
122122
try {
123123
server.close();
124124
} catch (Exception ex) {
125-
new RuntimeException(ex).printStackTrace();
125+
ex.printStackTrace();
126126
}
127127
server = null;
128128
try {
129129
port.close();
130130
} catch (Exception ex) {
131-
new RuntimeException(ex).printStackTrace();
131+
ex.printStackTrace();
132132
}
133133
port = null;
134134
}
@@ -169,19 +169,19 @@ public void tearDown() {
169169
try {
170170
client.close();
171171
} catch (Exception ex) {
172-
new RuntimeException(ex).printStackTrace();
172+
ex.printStackTrace();
173173
}
174174
client = null;
175175
try {
176176
server.close();
177177
} catch (Exception ex) {
178-
new RuntimeException(ex).printStackTrace();
178+
ex.printStackTrace();
179179
}
180180
server = null;
181181
try {
182182
port.close();
183183
} catch (Exception ex) {
184-
new RuntimeException(ex).printStackTrace();
184+
ex.printStackTrace();
185185
}
186186
port = null;
187187
}
@@ -196,7 +196,7 @@ public void benchUnary(final UnaryState state, final Blackhole blackhole) {
196196
}
197197
} catch (Exception e) {
198198
// Keep running because network may fail sometimes.
199-
new RuntimeException(e).printStackTrace();
199+
e.printStackTrace();
200200
}
201201
}
202202

@@ -216,7 +216,9 @@ public void onNext(HelloReply item) throws RuntimeException {
216216
public void onSubscribe(Flow.Subscription subscription) {}
217217

218218
@Override
219-
public void onError(Throwable throwable) {}
219+
public void onError(Throwable throwable) {
220+
new RuntimeException(throwable).printStackTrace();
221+
}
220222

221223
@Override
222224
public void onComplete() {
@@ -231,7 +233,7 @@ public void onComplete() {
231233
}
232234
} catch (Exception e) {
233235
// Keep running because network may fail sometimes.
234-
new RuntimeException(e).printStackTrace();
236+
e.printStackTrace();
235237
}
236238
}
237239

@@ -274,7 +276,7 @@ public void onComplete() {
274276
}
275277
} catch (Exception e) {
276278
// Keep running because network may fail sometimes.
277-
new RuntimeException(e).printStackTrace();
279+
e.printStackTrace();
278280
}
279281
}
280282

@@ -317,7 +319,7 @@ public void onComplete() {
317319
}
318320
} catch (Exception e) {
319321
// Keep running because network may fail sometimes.
320-
new RuntimeException(e).printStackTrace();
322+
e.printStackTrace();
321323
}
322324
}
323325

0 commit comments

Comments
 (0)