Error returns the error that occurred during reading data in background.
()
| 182 | |
| 183 | // Error returns the error that occurred during reading data in background. |
| 184 | func (ab *AsyncBuffer) Error() error { |
| 185 | err := ab.err.Load() |
| 186 | if err == nil { |
| 187 | return nil |
| 188 | } |
| 189 | |
| 190 | errCast, ok := err.(error) |
| 191 | if !ok { |
| 192 | return errors.New("asyncbuffer.AsyncBuffer.Error: failed to get error") |
| 193 | } |
| 194 | |
| 195 | return errCast |
| 196 | } |
| 197 | |
| 198 | // Close closes the AsyncBuffer and releases all resources. It is idempotent. |
| 199 | func (ab *AsyncBuffer) Close() error { |
no test coverage detected