func()

in ecr/stream/chunked_processor.go [101:128]

• 24 lines of code
• 8 McCabe index (conditional complexity)

func (processor *chunkedProcessor) readIntoChunks() {
	var currentBytes, currentPart int64
	defer close(processor.readChannel)

	for {
		select {
		case <-processor.ctx.Done():
			return
		default:
			chunk, err := processor.readChunk(currentBytes, currentPart)
			if err != nil && err != io.EOF {
				processor.errorChannel <- err
				return
			}

			if chunk != nil {
				processor.readChannel <- chunk
				currentBytes = chunk.BytesEnd + 1
				currentPart++
			}

			if err != nil && err == io.EOF {
				return
			}
		}
	}

}