Write 实现 ResponseWriter 接口
(b []byte)
| 136 | |
| 137 | // Write 实现 ResponseWriter 接口 |
| 138 | func (w *StreamResponseInterceptor) Write(b []byte) (int, error) { |
| 139 | // 收集响应内容 |
| 140 | w.collector.Collect(b) |
| 141 | // 同时转发给客户端 |
| 142 | return w.ResponseWriter.Write(b) |
| 143 | } |
| 144 | |
| 145 | // WriteHeader 实现 ResponseWriter 接口 |
| 146 | func (w *StreamResponseInterceptor) WriteHeader(statusCode int) { |