(t *testing.T)
| 43 | } |
| 44 | |
| 45 | func TestCSUPBatchBug(t *testing.T) { |
| 46 | var b bytes.Buffer |
| 47 | w := csup.NewSerializer(sio.NopCloser(&b)) |
| 48 | sctx := super.NewContext() |
| 49 | v1, err := sup.ParseValue(sctx, `{a: [1,2,3]}`) |
| 50 | require.NoError(t, err) |
| 51 | val2, err := sup.ParseValue(sctx, `{a:[4,5]}`) |
| 52 | require.NoError(t, err) |
| 53 | err = w.Push(valToVec(sctx, v1)) |
| 54 | require.NoError(t, err) |
| 55 | err = w.Push(valToVec(sctx, val2)) |
| 56 | err = w.Close() |
| 57 | require.NoError(t, err) |
| 58 | r, err := csupio.NewReader(sctx, bytes.NewReader(b.Bytes()), nil) |
| 59 | require.NoError(t, err) |
| 60 | val, err := r.Read() |
| 61 | require.NoError(t, err) |
| 62 | require.Equal(t, "{a:[1,2,3]}", sup.String(val)) |
| 63 | val, err = r.Read() |
| 64 | require.NoError(t, err) |
| 65 | require.Equal(t, "{a:[4,5]}", sup.String(val)) |
| 66 | } |
| 67 | |
| 68 | func valToVec(sctx *super.Context, val super.Value) vector.Any { |
| 69 | b := vector.NewDynamicBuilder() |
nothing calls this directly
no test coverage detected