()
| 804 | } |
| 805 | |
| 806 | func (cs *clientStream) Context() context.Context { |
| 807 | cs.commitAttempt() |
| 808 | // No need to lock before using attempt, since we know it is committed and |
| 809 | // cannot change. |
| 810 | if cs.attempt.transportStream != nil { |
| 811 | return cs.attempt.transportStream.Context() |
| 812 | } |
| 813 | return cs.ctx |
| 814 | } |
| 815 | |
| 816 | func (cs *clientStream) withRetry(op func(a *csAttempt) error, onSuccess func()) error { |
| 817 | cs.mu.Lock() |
no test coverage detected