(t *testing.T)
| 177 | } |
| 178 | |
| 179 | func TestBrokerError(t *testing.T) { |
| 180 | broker1, broker2 := setupBrokerPair() |
| 181 | |
| 182 | reader, meta := broker1.CreateStreamReader("reader1", "writer1", 1024) |
| 183 | writer, err := broker2.CreateStreamWriter(meta) |
| 184 | if err != nil { |
| 185 | t.Fatalf("CreateStreamWriter failed: %v", err) |
| 186 | } |
| 187 | |
| 188 | testErr := io.ErrUnexpectedEOF |
| 189 | writer.CloseWithError(testErr) |
| 190 | |
| 191 | buf := make([]byte, 1024) |
| 192 | _, err = reader.Read(buf) |
| 193 | if err == nil { |
| 194 | t.Fatal("Expected error from read") |
| 195 | } |
| 196 | if err.Error() != "stream error: unexpected EOF" { |
| 197 | t.Fatalf("Expected stream error, got: %v", err) |
| 198 | } |
| 199 | } |
| 200 | |
| 201 | func TestBrokerCancel(t *testing.T) { |
| 202 | broker1, broker2 := setupBrokerPair() |
nothing calls this directly
no test coverage detected