feat(codec): Improve compression flag log (#374)
This commit is contained in:
@@ -168,10 +168,15 @@ impl<T> Streaming<T> {
|
|||||||
}
|
}
|
||||||
f => {
|
f => {
|
||||||
trace!("unexpected compression flag");
|
trace!("unexpected compression flag");
|
||||||
return Err(Status::new(
|
let message = if let Direction::Response(status) = self.direction {
|
||||||
Code::Internal,
|
format!(
|
||||||
format!("Unexpected compression flag: {}", f),
|
"Unexpected compression flag: {}, while receiving response with status: {}",
|
||||||
));
|
f, status
|
||||||
|
)
|
||||||
|
} else {
|
||||||
|
format!("Unexpected compression flag: {}, while sending request", f)
|
||||||
|
};
|
||||||
|
return Err(Status::new(Code::Internal, message));
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
let len = self.buf.get_u32() as usize;
|
let len = self.buf.get_u32() as usize;
|
||||||
|
|||||||
Reference in New Issue
Block a user