()
| 329 | } |
| 330 | |
| 331 | func (s *Stream) getState() streamState { |
| 332 | return streamState(atomic.LoadUint32((*uint32)(&s.state))) |
| 333 | } |
| 334 | |
| 335 | // Trailer returns the cached trailer metadata. Note that if it is not called |
| 336 | // after the entire stream is done, it could return an empty MD. |
no test coverage detected