Skip to content

Commit

Permalink
chore: rename
Browse files Browse the repository at this point in the history
  • Loading branch information
jcosentino11 committed Oct 27, 2023
1 parent 6a99511 commit ae9533e
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -95,14 +95,14 @@ public class CISShadowMonitor implements Consumer<NetworkStateProvider.Connectio
if (stopped.get()) {
return;
}
reportShadowReceived();
signalShadowResponseReceived();
processCISShadow(resp);
};
private final Consumer<ErrorResponse> onGetShadowRejected = err -> {
if (stopped.get()) {
return;
}
reportShadowReceived();
signalShadowResponseReceived();
};

private final Object getShadowLock = new Object();
Expand Down Expand Up @@ -409,7 +409,10 @@ private void subscribeToShadowTopics() throws InterruptedException, ExecutionExc
subscribed.set(true);
}

private void reportShadowReceived() {
/**
* Called when a shadow response, either accepted or rejected, is received.
*/
private void signalShadowResponseReceived() {
CompletableFuture<?> shadowReceived = this.getShadowResponseReceived.get();
if (shadowReceived != null) {
shadowReceived.complete(null);
Expand Down

0 comments on commit ae9533e

Please sign in to comment.