(b []byte)
| 106 | } |
| 107 | |
| 108 | func (s *stateTrackingStream) Read(b []byte) (int, error) { |
| 109 | n, err := s.Stream.Read(b) |
| 110 | if err != nil && !errors.Is(err, os.ErrDeadlineExceeded) { |
| 111 | s.closeReceive(err) |
| 112 | } |
| 113 | return n, err |
| 114 | } |
| 115 | |
| 116 | func (s *stateTrackingStream) SendDatagram(b []byte) error { |
| 117 | s.mx.Lock() |
nothing calls this directly
no test coverage detected