Skip to content

Commit 087be17

Browse files
refactor!: rename JetstreamError2::Status to JetstreamError2::Api
1 parent 9d7d56d commit 087be17

File tree

1 file changed

+5
-5
lines changed
  • watermelon/src/client/jetstream

1 file changed

+5
-5
lines changed

watermelon/src/client/jetstream/mod.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ pub enum JetstreamError2 {
6363
#[error("JSON deserialization")]
6464
Json(#[source] serde_json::Error),
6565
#[error("bad response code")]
66-
Status(#[source] JetstreamApiError),
66+
Api(#[source] JetstreamApiError),
6767
}
6868

6969
impl JetstreamClient {
@@ -119,7 +119,7 @@ impl JetstreamClient {
119119
.map_err(JetstreamError2::Json)?;
120120
match json {
121121
Response::Response(stream) => Ok(stream),
122-
Response::Error { error } => Err(JetstreamError2::Status(error)),
122+
Response::Error { error } => Err(JetstreamError2::Api(error)),
123123
}
124124
}
125125

@@ -152,7 +152,7 @@ impl JetstreamClient {
152152
Response::Error { error } if error.code == JetstreamErrorCode::STREAM_NOT_FOUND => {
153153
Ok(None)
154154
}
155-
Response::Error { error } => Err(JetstreamError2::Status(error)),
155+
Response::Error { error } => Err(JetstreamError2::Api(error)),
156156
}
157157
}
158158

@@ -196,7 +196,7 @@ impl JetstreamClient {
196196
.map_err(JetstreamError2::Json)?;
197197
match json {
198198
Response::Response(consumer) => Ok(consumer),
199-
Response::Error { error } => Err(JetstreamError2::Status(error)),
199+
Response::Error { error } => Err(JetstreamError2::Api(error)),
200200
}
201201
}
202202

@@ -236,7 +236,7 @@ impl JetstreamClient {
236236
Response::Error { error } if error.code == JetstreamErrorCode::CONSUMER_NOT_FOUND => {
237237
Ok(None)
238238
}
239-
Response::Error { error } => Err(JetstreamError2::Status(error)),
239+
Response::Error { error } => Err(JetstreamError2::Api(error)),
240240
}
241241
}
242242

0 commit comments

Comments
 (0)