mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-07-09 06:14:06 +00:00
Fix linter
This commit is contained in:
parent
2433d867af
commit
5061e97018
@ -8,7 +8,6 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
type golangReader struct {
|
type golangReader struct {
|
||||||
key string
|
|
||||||
msgQueue chan []byte
|
msgQueue chan []byte
|
||||||
data []byte
|
data []byte
|
||||||
progress *api.ReadProgress
|
progress *api.ReadProgress
|
||||||
@ -55,14 +54,12 @@ func (r *golangReader) Read(p []byte) (int, error) {
|
|||||||
|
|
||||||
for len(r.data) == 0 {
|
for len(r.data) == 0 {
|
||||||
var ok bool
|
var ok bool
|
||||||
select {
|
b, ok = <-r.msgQueue
|
||||||
case b, ok = <-r.msgQueue:
|
|
||||||
if !ok {
|
if !ok {
|
||||||
return 0, io.EOF
|
return 0, io.EOF
|
||||||
}
|
}
|
||||||
|
|
||||||
r.data = b
|
r.data = b
|
||||||
}
|
|
||||||
|
|
||||||
if len(r.data) > 0 {
|
if len(r.data) > 0 {
|
||||||
break
|
break
|
||||||
|
Loading…
Reference in New Issue
Block a user