final NormalizedNodeDataInput ret;
switch (version) {
case TokenTypes.LITHIUM_VERSION:
- ret = new NormalizedNodeInputStreamReader(input);
+ ret = new LithiumNormalizedNodeInputStreamReader(input);
+ break;
+ case TokenTypes.NEON_SR2_VERSION:
+ ret = new NeonSR2NormalizedNodeInputStreamReader(input);
+ break;
+ case TokenTypes.SODIUM_SR1_VERSION:
+ ret = new SodiumSR1DataInput(input);
+ break;
+ case TokenTypes.MAGNESIUM_VERSION:
+ ret = new MagnesiumDataInput(input);
break;
default:
throw defunct("Unhandled stream version %s", version);