reword error: channel is _terminated and_ empty (#3041)

This commit is contained in:
Bernhard Schuster
2021-05-18 07:51:46 +02:00
committed by GitHub
parent e9615fc9df
commit 2a6f460e4c
+3 -3
View File
@@ -887,7 +887,7 @@ impl<M: Send + 'static> SubsystemContext for OverseerSubsystemContext<M> {
// wait for next signal.
let signal = self.signals.next().await
.ok_or(SubsystemError::Context(
"No more messages in rx queue to process"
"Signal channel is terminated and empty."
.to_owned()
))?;
@@ -906,7 +906,7 @@ impl<M: Send + 'static> SubsystemContext for OverseerSubsystemContext<M> {
signal = await_signal => {
let signal = signal
.ok_or(SubsystemError::Context(
"No more messages in rx queue to process"
"Signal channel is terminated and empty."
.to_owned()
))?;
@@ -915,7 +915,7 @@ impl<M: Send + 'static> SubsystemContext for OverseerSubsystemContext<M> {
msg = await_message => {
let packet = msg
.ok_or(SubsystemError::Context(
"No more messages in rx queue to process"
"Message channel is terminated and empty."
.to_owned()
))?;