Function newBlockingErrTransport

client/core_test.go:483–490

(err error)

}

func newBlockingErrTransport(err error) *blockingErrTransport {
	return &blockingErrTransport{
		err:      err,
		called:   make(chan struct{}),
		unblock:  make(chan struct{}),
		finished: make(chan struct{}),
	}
}

func (b *blockingErrTransport) Do(_ *fasthttp.Request, _ *fasthttp.Response) error {
	b.calledOnce.Do(func() { close(b.called) })