Skip to content

Commit 64c4ea5

Browse files
authored
Handle ignored message as a failure (#218)
1 parent 6fd6342 commit 64c4ea5

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

lib/src/stream.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,10 @@ impl RowStream {
233233
None
234234
}
235235
},
236-
Summary::Ignored => None,
236+
Summary::Ignored => {
237+
self.state = State::Complete(None);
238+
return Err(Error::RequestIgnoredError);
239+
}
237240
Summary::Failure(f) => {
238241
self.state = State::Complete(None);
239242
return Err(f.into_error());

0 commit comments

Comments
 (0)