Skip to content

Commit 19d6967

Browse files
nficanoclaude
andcommitted
style: drop section-divider comments from client/runtime/tck
Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
1 parent fe9ce95 commit 19d6967

3 files changed

Lines changed: 0 additions & 20 deletions

File tree

arcp-client/src/main/java/dev/arcp/client/ArcpClient.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -237,8 +237,6 @@ public void onComplete() {
237237
}
238238
}
239239

240-
// ---------------------------------------------------------- inbound
241-
242240
private void dispatch(Envelope envelope) {
243241
Message m;
244242
try {
@@ -402,8 +400,6 @@ private void handlePing(SessionPing ping) {
402400
send(Message.Type.SESSION_PONG, pong, sessionId, null, null, null);
403401
}
404402

405-
// ---------------------------------------------------------- send
406-
407403
private void send(
408404
Message.Type type,
409405
Message payload,
@@ -428,8 +424,6 @@ private void send(
428424
transport.send(env);
429425
}
430426

431-
// ---------------------------------------------------------- internals
432-
433427
private final class Outstanding {
434428
final CompletableFuture<JobHandle> handleFuture = new CompletableFuture<>();
435429
final CompletableFuture<JobResult> resultFuture = new CompletableFuture<>();

arcp-runtime/src/main/java/dev/arcp/runtime/session/SessionLoop.java

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -178,8 +178,6 @@ public void shutdown(String reason) {
178178
runtime.removeSession(this);
179179
}
180180

181-
// ---------------------------------------------------------- dispatch
182-
183181
private void handle(Envelope envelope) {
184182
Phase p = phase;
185183
Message m;
@@ -222,8 +220,6 @@ private void handle(Envelope envelope) {
222220
}
223221
}
224222

225-
// ---------------------------------------------------------- handshake
226-
227223
private void doHandshake(SessionHello hello) {
228224
try {
229225
Principal pr = authenticate(hello);
@@ -275,8 +271,6 @@ private Principal authenticate(SessionHello hello) throws ArcpException {
275271
"unsupported auth scheme: " + auth.scheme());
276272
}
277273

278-
// ---------------------------------------------------------- heartbeat
279-
280274
private void tickHeartbeat(Duration interval) {
281275
if (phase != Phase.ACTIVE) {
282276
return;
@@ -293,8 +287,6 @@ private void tickHeartbeat(Duration interval) {
293287
}
294288
}
295289

296-
// ---------------------------------------------------------- control
297-
298290
private void handleBye(SessionBye bye) {
299291
log.debug("session {} bye: {}", sessionId, bye.reason());
300292
shutdown("client bye");
@@ -336,8 +328,6 @@ private void handleListJobs(MessageId requestId, SessionListJobs req) {
336328
send(Message.Type.SESSION_JOBS, response, sessionId, null, null, null);
337329
}
338330

339-
// ---------------------------------------------------------- jobs
340-
341331
private void handleSubmit(Envelope envelope, JobSubmit submit) {
342332
Principal pr = principal;
343333
if (pr == null) {
@@ -600,8 +590,6 @@ private void handleUnsubscribe(JobUnsubscribe unsub) {
600590
}
601591
}
602592

603-
// ---------------------------------------------------------- emission
604-
605593
private void emitJobEvent(JobRecord record, EventBody body) {
606594
long seq = nextSeq();
607595
record.setLastEventSeq(seq);

arcp-tck/src/main/java/dev/arcp/tck/ConformanceSuite.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,6 @@ private interface Assertion {
7878
void run(TckProvider provider, ArcpClient client) throws Exception;
7979
}
8080

81-
// ------------------------------------------------------ assertions
82-
8381
private static void handshakeReturnsWelcome(TckProvider p, ArcpClient client) throws Exception {
8482
Session session = client.connect(Duration.ofSeconds(5));
8583
assertThat(session.sessionId()).isNotNull();

0 commit comments

Comments
 (0)