()
| 367 | var errSessionClosing = errors.New("session is closing") |
| 368 | |
| 369 | func (sess *daggerSession) beginClosing() { |
| 370 | sess.closeClosingOnce.Do(func() { |
| 371 | if sess.cancelClosing != nil { |
| 372 | sess.cancelClosing(errSessionClosing) |
| 373 | } |
| 374 | }) |
| 375 | } |
| 376 | |
| 377 | func (sess *daggerSession) withClosingCancel(ctx context.Context) context.Context { |
| 378 | ctx, cancel := context.WithCancelCause(ctx) |
no test coverage detected