Fixes NPEs in TranscodingAsyncConsistentMap deserialization code paths
Change-Id: I7898a08d0b999fd6c84ead616856f04bc9765ed5
Showing
1 changed file
with
2 additions
and
2 deletions
... | @@ -60,9 +60,9 @@ public class TranscodingAsyncConsistentMap<K1, V1, K2, V2> implements AsyncConsi | ... | @@ -60,9 +60,9 @@ public class TranscodingAsyncConsistentMap<K1, V1, K2, V2> implements AsyncConsi |
60 | Function<V2, V1> valueDecoder) { | 60 | Function<V2, V1> valueDecoder) { |
61 | this.backingMap = backingMap; | 61 | this.backingMap = backingMap; |
62 | this.keyEncoder = k -> k == null ? null : keyEncoder.apply(k); | 62 | this.keyEncoder = k -> k == null ? null : keyEncoder.apply(k); |
63 | - this.keyDecoder = keyDecoder; | 63 | + this.keyDecoder = k -> k == null ? null : keyDecoder.apply(k); |
64 | this.valueEncoder = v -> v == null ? null : valueEncoder.apply(v); | 64 | this.valueEncoder = v -> v == null ? null : valueEncoder.apply(v); |
65 | - this.valueDecoder = valueDecoder; | 65 | + this.valueDecoder = v -> v == null ? null : valueDecoder.apply(v); |
66 | this.versionedValueTransform = v -> v == null ? null : v.map(valueDecoder); | 66 | this.versionedValueTransform = v -> v == null ? null : v.map(valueDecoder); |
67 | } | 67 | } |
68 | 68 | ... | ... |
-
Please register or login to post a comment