(t *testing.T, msg []byte)
| 2159 | } |
| 2160 | |
| 2161 | func getKey(t *testing.T, msg []byte) string { |
| 2162 | kvPair := KeyValuePair{} |
| 2163 | err := kvPair.Unmarshal(msg) |
| 2164 | require.NoError(t, err) |
| 2165 | return kvPair.Key |
| 2166 | } |
| 2167 | |
| 2168 | func TestRaceBetweenStoringNewValueForKeyAndUpdatingIt(t *testing.T) { |
| 2169 | codec := dataCodec{} |
no test coverage detected