diff --git a/couch_rs/src/changes.rs b/couch_rs/src/changes.rs index 173f0a1..d4fca63 100644 --- a/couch_rs/src/changes.rs +++ b/couch_rs/src/changes.rs @@ -112,7 +112,11 @@ impl Stream for ChangesStream { ChangesStreamState::Idle => { let mut params = self.params.clone(); if let Some(seq) = &self.last_seq { - params.insert("since".to_string(), seq.to_string()); + let seq = match seq { + serde_json::Value::String(seq) => seq.to_string(), + _ => seq.to_string(), + }; + params.insert("since".to_string(), seq); } let fut = get_changes(self.client.clone(), self.database.clone(), params); ChangesStreamState::Requesting(Box::pin(fut))