(data []byte)
| 130 | } |
| 131 | |
| 132 | func (w *mockSSERespWriter) Write(data []byte) (int, error) { |
| 133 | newData := make([]byte, len(data)) |
| 134 | copy(newData, data) |
| 135 | |
| 136 | w.writeNotification <- newData |
| 137 | return len(data), nil |
| 138 | } |
| 139 | |
| 140 | func (w *mockSSERespWriter) WriteString(str string) (int, error) { |
| 141 | return w.Write([]byte(str)) |