1394329e44
* move error_accumulator into internal pkg (#304) * move error_accumulator into internal pkg (#304) * add a test for ErrTooManyEmptyStreamMessages in stream_reader (#304)
22 lines
390 B
Go
22 lines
390 B
Go
package test
|
|
|
|
import "errors"
|
|
|
|
var (
|
|
ErrTestErrorAccumulatorWriteFailed = errors.New("test error accumulator failed")
|
|
)
|
|
|
|
type FailingErrorBuffer struct{}
|
|
|
|
func (b *FailingErrorBuffer) Write(_ []byte) (n int, err error) {
|
|
return 0, ErrTestErrorAccumulatorWriteFailed
|
|
}
|
|
|
|
func (b *FailingErrorBuffer) Len() int {
|
|
return 0
|
|
}
|
|
|
|
func (b *FailingErrorBuffer) Bytes() []byte {
|
|
return []byte{}
|
|
}
|