From 3ca64fd5ba6030cf0c9a1a7def3706a568f91cd0 Mon Sep 17 00:00:00 2001 From: Jerome Froelich Date: Tue, 2 May 2017 18:00:42 +0300 Subject: [PATCH] Fix comments --- protocol/msgpack/aggregated_iterator_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/protocol/msgpack/aggregated_iterator_test.go b/protocol/msgpack/aggregated_iterator_test.go index 7854fdb..64f80e2 100644 --- a/protocol/msgpack/aggregated_iterator_test.go +++ b/protocol/msgpack/aggregated_iterator_test.go @@ -173,13 +173,13 @@ func TestAggregatedIteratorPolicyDecompressedNotEnabledError(t *testing.T) { policy: testPolicy, } - // Use an encoder which compresses testPolicy + // Use an encoder which compresses testPolicy. enc := testAggregatedEncoder(t, testBaseEncoderOptions).(*aggregatedEncoder) testAggregatedEncode(t, enc, input.metric.(aggregated.Metric), input.policy) require.NoError(t, enc.err()) - // Use an iterator which does not have decompression enabled + // Use an iterator which does not have decompression enabled. it := testAggregatedIterator(t, enc.Encoder().Buffer(), nil) validateAggregatedDecodeResults(t, it, nil, errPolicyDecompressionNotEnabled) @@ -191,13 +191,13 @@ func TestAggregatedIteratorUnrecognizedCompressedPolicyError(t *testing.T) { policy: testPolicy, } - // Use an encoder which compresses testPolicy + // Use an encoder which compresses testPolicy. enc := testAggregatedEncoder(t, testBaseEncoderOptions).(*aggregatedEncoder) testAggregatedEncode(t, enc, input.metric.(aggregated.Metric), input.policy) require.NoError(t, enc.err()) - // Use an iterator which does not have testPolicy in it's decompressor + // Use an iterator which does not have testPolicy in it's decompressor. baseItOpts := baseIteratorOptions{ enabled: true, decompressor: policy.NewNoopDecompressor(),