| 469 | } |
| 470 | |
| 471 | type blockingErrTransport struct { |
| 472 | err error |
| 473 | |
| 474 | called chan struct{} |
| 475 | unblock chan struct{} |
| 476 | finished chan struct{} |
| 477 | |
| 478 | calledOnce sync.Once |
| 479 | releaseOnce sync.Once |
| 480 | finishedOnce sync.Once |
| 481 | } |
| 482 | |
| 483 | func newBlockingErrTransport(err error) *blockingErrTransport { |
| 484 | return &blockingErrTransport{ |
nothing calls this directly
no outgoing calls
no test coverage detected