Function TestSkipPrimitiveConsumesExactEncoding

go/fory/skip_test.go:45–114

(t *testing.T)

}

func TestSkipPrimitiveConsumesExactEncoding(t *testing.T) {
	tests := []struct {
		name   string
		typeID TypeId
		write  func(*ByteBuffer)
	}{
		{
			name:   "int32",
			typeID: INT32,
			write:  func(buf *ByteBuffer) { buf.WriteInt32(0x01020304) },
		},
		{
			name:   "varint32",
			typeID: VARINT32,
			write:  func(buf *ByteBuffer) { buf.WriteVarint32(300) },
		},
		{
			name:   "int64",
			typeID: INT64,
			write:  func(buf *ByteBuffer) { buf.WriteInt64(0x0102030405060708) },
		},
		{
			name:   "varint64",
			typeID: VARINT64,
			write:  func(buf *ByteBuffer) { buf.WriteVarint64(1 << 35) },
		},
		{
			name:   "tagged_int64_small",
			typeID: TAGGED_INT64,
			write:  func(buf *ByteBuffer) { buf.WriteTaggedInt64(1073741823) },
		},
		{
			name:   "tagged_int64_large",
			typeID: TAGGED_INT64,
			write:  func(buf *ByteBuffer) { buf.WriteTaggedInt64(1 << 40) },
		},
		{
			name:   "tagged_uint64_small",
			typeID: TAGGED_UINT64,
			write:  func(buf *ByteBuffer) { buf.WriteTaggedUint64(0x7fffffff) },
		},
		{
			name:   "tagged_uint64_large",
			typeID: TAGGED_UINT64,
			write:  func(buf *ByteBuffer) { buf.WriteTaggedUint64(1 << 40) },
		},
	}

	for _, tc := range tests {
		t.Run(tc.name, func(t *testing.T) {
			f := New(WithXlang(true), WithCompatible(false))
			buf := NewByteBuffer(nil)
			tc.write(buf)
			wantIndex := buf.WriterIndex()
			buf.WriteByte(0x7f)

			f.readCtx.SetData(buf.Bytes())
			skipValue(