()
| 51 | } |
| 52 | |
| 53 | func newBiStreamStatus() *bidirectionalStreamStatus { |
| 54 | return &bidirectionalStreamStatus{ |
| 55 | doneChan: make(chan struct{}, 2), |
| 56 | anyDone: 0, |
| 57 | } |
| 58 | } |
| 59 | |
| 60 | func (s *bidirectionalStreamStatus) markUniStreamDone() { |
| 61 | atomic.StoreUint32(&s.anyDone, 1) |