|
37 | 37 | import org.msgpack.value.Value; |
38 | 38 | import org.msgpack.value.ImmutableValue; |
39 | 39 | import org.msgpack.value.Variable; |
40 | | -import org.msgpack.value.ValueType; |
41 | 40 | import org.msgpack.value.ValueFactory; |
42 | 41 |
|
43 | 42 | import static org.msgpack.core.Preconditions.*; |
@@ -580,9 +579,9 @@ public ImmutableValue unpackValue() throws IOException { |
580 | 579 | } |
581 | 580 | return ValueFactory.newMapValue(kvs); |
582 | 581 | } |
583 | | - case EXTENDED: { |
584 | | - ExtendedTypeHeader extHeader = unpackExtendedTypeHeader(); |
585 | | - return ValueFactory.newExtendedValue(extHeader.getType(), readPayload(extHeader.getLength())); |
| 582 | + case EXTENSION: { |
| 583 | + ExtensionTypeHeader extHeader = unpackExtensionTypeHeader(); |
| 584 | + return ValueFactory.newExtensionValue(extHeader.getType(), readPayload(extHeader.getLength())); |
586 | 585 | } |
587 | 586 | default: |
588 | 587 | throw new MessageFormatException("Unknown value type"); |
@@ -648,9 +647,9 @@ public Variable unpackValue(Variable var) throws IOException { |
648 | 647 | var.setMapValue(map); |
649 | 648 | return var; |
650 | 649 | } |
651 | | - case EXTENDED: { |
652 | | - ExtendedTypeHeader extHeader = unpackExtendedTypeHeader(); |
653 | | - var.setExtendedValue(extHeader.getType(), readPayload(extHeader.getLength())); |
| 650 | + case EXTENSION: { |
| 651 | + ExtensionTypeHeader extHeader = unpackExtensionTypeHeader(); |
| 652 | + var.setExtensionValue(extHeader.getType(), readPayload(extHeader.getLength())); |
654 | 653 | return var; |
655 | 654 | } |
656 | 655 | default: |
@@ -1042,33 +1041,33 @@ public int unpackMapHeader() throws IOException { |
1042 | 1041 | throw unexpected("Map", b); |
1043 | 1042 | } |
1044 | 1043 |
|
1045 | | - public ExtendedTypeHeader unpackExtendedTypeHeader() throws IOException { |
| 1044 | + public ExtensionTypeHeader unpackExtensionTypeHeader() throws IOException { |
1046 | 1045 | byte b = consume(); |
1047 | 1046 | switch(b) { |
1048 | 1047 | case Code.FIXEXT1: |
1049 | | - return new ExtendedTypeHeader(readByte(), 1); |
| 1048 | + return new ExtensionTypeHeader(readByte(), 1); |
1050 | 1049 | case Code.FIXEXT2: |
1051 | | - return new ExtendedTypeHeader(readByte(), 2); |
| 1050 | + return new ExtensionTypeHeader(readByte(), 2); |
1052 | 1051 | case Code.FIXEXT4: |
1053 | | - return new ExtendedTypeHeader(readByte(), 4); |
| 1052 | + return new ExtensionTypeHeader(readByte(), 4); |
1054 | 1053 | case Code.FIXEXT8: |
1055 | | - return new ExtendedTypeHeader(readByte(), 8); |
| 1054 | + return new ExtensionTypeHeader(readByte(), 8); |
1056 | 1055 | case Code.FIXEXT16: |
1057 | | - return new ExtendedTypeHeader(readByte(), 16); |
| 1056 | + return new ExtensionTypeHeader(readByte(), 16); |
1058 | 1057 | case Code.EXT8: { |
1059 | 1058 | int length = readNextLength8(); |
1060 | 1059 | byte type = readByte(); |
1061 | | - return new ExtendedTypeHeader(type, length); |
| 1060 | + return new ExtensionTypeHeader(type, length); |
1062 | 1061 | } |
1063 | 1062 | case Code.EXT16: { |
1064 | 1063 | int length = readNextLength16(); |
1065 | 1064 | byte type = readByte(); |
1066 | | - return new ExtendedTypeHeader(type, length); |
| 1065 | + return new ExtensionTypeHeader(type, length); |
1067 | 1066 | } |
1068 | 1067 | case Code.EXT32: { |
1069 | 1068 | int length = readNextLength32(); |
1070 | 1069 | byte type = readByte(); |
1071 | | - return new ExtendedTypeHeader(type, length); |
| 1070 | + return new ExtensionTypeHeader(type, length); |
1072 | 1071 | } |
1073 | 1072 | } |
1074 | 1073 |
|
|
0 commit comments