final StreamObserver<AppendEntriesRequestProto> s;
synchronized (this) {
while (isAppenderRunning() && shouldWait()) {
try {
LOG.debug("{} wait to send the next AppendEntries to {}",
<BUG>server.getId(), follower.getPeer().getId());
this.wait();</BUG>
} catch (InterruptedException ignored) {
}
}

final StreamObserver<AppendEntriesRequestProto> s;
synchronized (this) {
while (isAppenderRunning() && shouldWait()) {
try {
LOG.debug("{} wait to send the next AppendEntries to {}",
server.getId(), follower.getPeer());
this.wait();
} catch (InterruptedException ignored) {
}
}
