(t *testing.T)
| 1034 | } |
| 1035 | |
| 1036 | func TestWriterFailure_OnCompression(t *testing.T) { |
| 1037 | _, _, om := setupTest(t, nil) |
| 1038 | |
| 1039 | compression.RegisterCompressor("faulty", &faultyCompressor{}) |
| 1040 | |
| 1041 | ctx := testlogging.Context(t) |
| 1042 | w := om.NewWriter(ctx, WriterOptions{ |
| 1043 | Compressor: "faulty", |
| 1044 | }) |
| 1045 | |
| 1046 | _, err := w.Write(bytes.Repeat([]byte{1, 2, 3, 4}, 1e6)) |
| 1047 | require.ErrorIs(t, err, errSomeError) |
| 1048 | } |