mirror of
https://github.com/aljazceru/crawler_v2.git
synced 2025-12-17 07:24:21 +01:00
better error message in send
This commit is contained in:
@@ -111,7 +111,7 @@ func Send[T any](ch chan T) Forward[T] {
|
|||||||
case ch <- t:
|
case ch <- t:
|
||||||
return nil
|
return nil
|
||||||
default:
|
default:
|
||||||
return fmt.Errorf("channel is full, dropping %v", t)
|
return fmt.Errorf("pipe.Send: channel is full, dropping %v", t)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user