(b []byte)
| 93 | } |
| 94 | |
| 95 | func (s *stateTrackingStream) Write(b []byte) (int, error) { |
| 96 | n, err := s.Stream.Write(b) |
| 97 | if err != nil && !errors.Is(err, os.ErrDeadlineExceeded) { |
| 98 | s.closeSend(err) |
| 99 | } |
| 100 | return n, err |
| 101 | } |
| 102 | |
| 103 | func (s *stateTrackingStream) CancelRead(e quic.StreamErrorCode) { |
| 104 | s.closeReceive(&quic.StreamError{StreamID: s.StreamID(), ErrorCode: e}) |