diff options
Diffstat (limited to 'workhorse/internal/helper/context_reader.go')
-rw-r--r-- | workhorse/internal/helper/context_reader.go | 40 |
1 files changed, 0 insertions, 40 deletions
diff --git a/workhorse/internal/helper/context_reader.go b/workhorse/internal/helper/context_reader.go deleted file mode 100644 index a4764043147..00000000000 --- a/workhorse/internal/helper/context_reader.go +++ /dev/null @@ -1,40 +0,0 @@ -package helper - -import ( - "context" - "io" -) - -type ContextReader struct { - ctx context.Context - underlyingReader io.Reader -} - -func NewContextReader(ctx context.Context, underlyingReader io.Reader) *ContextReader { - return &ContextReader{ - ctx: ctx, - underlyingReader: underlyingReader, - } -} - -func (r *ContextReader) Read(b []byte) (int, error) { - if r.canceled() { - return 0, r.err() - } - - n, err := r.underlyingReader.Read(b) - - if r.canceled() { - err = r.err() - } - - return n, err -} - -func (r *ContextReader) canceled() bool { - return r.err() != nil -} - -func (r *ContextReader) err() error { - return r.ctx.Err() -} |