Apply changes and deconflicts while #366 was pending.

Signed-off-by: Jason Volk <jason@zemos.net>

Author: jevolk

src/service/replication/mod.rs

@@ -99,7 +99,7 @@ impl crate::Service for Service {
 		}
 
 		loop {
-			if !self.server.running() {
+			if !self.server.is_running() {
 				return Ok(());
 			}
 
@@ -146,7 +146,7 @@ impl crate::Service for Service {
 
 			let mut backoff_ms = BACKOFF_MIN_MS;
 
-			while self.server.running() && !self.promoted.load(Ordering::Acquire) {
+			while self.server.is_running() && !self.promoted.load(Ordering::Acquire) {
 				match self.run_stream(&primary_url).await {
 					| Ok(()) => {
 						// run_stream returns Ok on clean shutdown or promotion.
@@ -259,7 +259,7 @@ impl Service {
 		let mut byte_stream = resp.bytes_stream();
 		let mut buf: Vec<u8> = Vec::new();
 
-		while self.server.running() && !self.promoted.load(Ordering::Acquire) {
+		while self.server.is_running() && !self.promoted.load(Ordering::Acquire) {
 			tokio::select! {
 				chunk = byte_stream.next() => {
 					let Some(chunk) = chunk else {