2020import static org .assertj .core .data .Offset .offset ;
2121
2222import java .io .IOException ;
23+ import java .time .Duration ;
2324import java .util .Collection ;
2425import java .util .Collections ;
2526import java .util .HashSet ;
@@ -139,16 +140,19 @@ void testLexCountBounded() {
139140 void testPopMin () {
140141
141142 K key = keyFactory .instance ();
143+ V value0 = valueFactory .instance ();
142144 V value1 = valueFactory .instance ();
143145 V value2 = valueFactory .instance ();
144146 V value3 = valueFactory .instance ();
145147 V value4 = valueFactory .instance ();
146148
149+ zSetOps .add (key , value0 , 0 );
147150 zSetOps .add (key , value1 , 1 );
148151 zSetOps .add (key , value2 , 2 );
149152 zSetOps .add (key , value3 , 3 );
150153 zSetOps .add (key , value4 , 4 );
151154
155+ assertThat (zSetOps .popMin (key , Duration .ofSeconds (1 ))).isEqualTo (new DefaultTypedTuple <>(value0 , 0d ));
152156 assertThat (zSetOps .popMin (key )).isEqualTo (new DefaultTypedTuple <>(value1 , 1d ));
153157 assertThat (zSetOps .popMin (key , 2 )).containsExactly (new DefaultTypedTuple <>(value2 , 2d ),
154158 new DefaultTypedTuple <>(value3 , 3d ));
@@ -164,12 +168,15 @@ void testPopMax() {
164168 V value2 = valueFactory .instance ();
165169 V value3 = valueFactory .instance ();
166170 V value4 = valueFactory .instance ();
171+ V value5 = valueFactory .instance ();
167172
168173 zSetOps .add (key , value1 , 1 );
169174 zSetOps .add (key , value2 , 2 );
170175 zSetOps .add (key , value3 , 3 );
171176 zSetOps .add (key , value4 , 4 );
177+ zSetOps .add (key , value5 , 5 );
172178
179+ assertThat (zSetOps .popMax (key , Duration .ofSeconds (1 ))).isEqualTo (new DefaultTypedTuple <>(value5 , 5d ));
173180 assertThat (zSetOps .popMax (key )).isEqualTo (new DefaultTypedTuple <>(value4 , 4d ));
174181 assertThat (zSetOps .popMax (key , 2 )).containsExactly (new DefaultTypedTuple <>(value3 , 3d ),
175182 new DefaultTypedTuple <>(value2 , 2d ));
0 commit comments