@@ -123,147 +123,3 @@ def test_cache_wait_expire(self):
123123 self .reactor .pump ((2 ,))
124124
125125 self .assertIsNone (cache .get (0 ), "cache should not have the result now" )
126-
127-
128- class ConditionalDeferredCacheTestCase (DeferredCacheTestCase ):
129- def test_one_false (self ):
130- cache = ResponseCache (self .synapse_clock , "keeping_cache" , timeout_ms = 9001 )
131-
132- texan_greeting = "howdy"
133- english_greeting = "greetings"
134-
135- def is_english_greeting (greeting ) -> bool :
136- return greeting == english_greeting
137-
138- wrap_d = cache .wrap_conditional (
139- 0 , is_english_greeting , self .instant_return , texan_greeting
140- )
141-
142- self .assertEqual (texan_greeting , self .successResultOf (wrap_d ))
143- self .assertIsNone (cache .get (0 ), "cache should not have the result" )
144-
145- def test_one_true (self ):
146- cache = ResponseCache (self .synapse_clock , "keeping_cache" , timeout_ms = 9001 )
147-
148- texan_greeting = "howdy"
149-
150- def is_texan_greeting (greeting ) -> bool :
151- return greeting == texan_greeting
152-
153- wrap_d = cache .wrap_conditional (
154- 0 , is_texan_greeting , self .instant_return , texan_greeting
155- )
156-
157- self .assertEqual (texan_greeting , self .successResultOf (wrap_d ))
158- self .assertEqual (
159- texan_greeting ,
160- self .successResultOf (cache .get (0 )),
161- "cache should have the result" ,
162- )
163-
164- def test_one_false_with_empty (self ):
165- cache = ResponseCache (self .synapse_clock , "keeping_cache" , timeout_ms = 9001 )
166-
167- texan_greeting = "howdy"
168- english_greeting = "greetings"
169-
170- def is_english_greeting (greeting ) -> bool :
171- return greeting == english_greeting
172-
173- wrap_d = cache .wrap_conditional (
174- 0 , is_english_greeting , self .delayed_return , texan_greeting
175- )
176- wrap_empty = cache .wrap (0 , self .delayed_return , texan_greeting )
177-
178- self .reactor .pump ((1 ,))
179-
180- self .assertEqual (texan_greeting , self .successResultOf (wrap_d ))
181- self .assertEqual (texan_greeting , self .successResultOf (wrap_empty ))
182- self .assertIsNone (cache .get (0 ), "cache should not have the result" )
183-
184- def test_one_true_with_empty (self ):
185- cache = ResponseCache (self .synapse_clock , "keeping_cache" , timeout_ms = 9001 )
186-
187- texan_greeting = "howdy"
188-
189- def is_texan_greeting (greeting ) -> bool :
190- return greeting == texan_greeting
191-
192- wrap_d = cache .wrap_conditional (
193- 0 , is_texan_greeting , self .delayed_return , texan_greeting
194- )
195- wrap_empty = cache .wrap (0 , self .delayed_return , texan_greeting )
196-
197- self .reactor .pump ((1 ,))
198-
199- self .assertEqual (texan_greeting , self .successResultOf (wrap_d ))
200- self .assertEqual (texan_greeting , self .successResultOf (wrap_empty ))
201- self .assertEqual (
202- texan_greeting ,
203- self .successResultOf (cache .get (0 )),
204- "cache should have the result" ,
205- )
206-
207- def test_multiple_mixed (self ):
208- cache = ResponseCache (self .synapse_clock , "keeping_cache" , timeout_ms = 9001 )
209-
210- texan_greeting = "howdy"
211- english_greeting = "greetings"
212-
213- def is_english_greeting (greeting ) -> bool :
214- return greeting == english_greeting
215-
216- def is_texan_greeting (greeting ) -> bool :
217- return greeting == texan_greeting
218-
219- negative_wrap = cache .wrap_conditional (
220- 0 , is_english_greeting , self .delayed_return , texan_greeting
221- )
222-
223- positive_wraps = {
224- cache .wrap_conditional (
225- 0 , is_texan_greeting , self .delayed_return , texan_greeting
226- )
227- for _ in range (5 )
228- }
229-
230- self .reactor .pump ((1 ,))
231-
232- for wrap in positive_wraps | {negative_wrap }:
233- self .assertEqual (
234- texan_greeting ,
235- self .successResultOf (wrap ),
236- "wrap deferred {!r} should have {!r}" .format (wrap , texan_greeting ),
237- )
238-
239- self .assertIsNone (cache .get (0 ), "cache should not have the result" )
240-
241- def test_multiple_true (self ):
242- cache = ResponseCache (self .synapse_clock , "keeping_cache" , timeout_ms = 9001 )
243-
244- texan_greeting = "howdy"
245-
246- def is_texan_greeting (greeting ) -> bool :
247- return greeting == texan_greeting
248-
249- positive_wraps = {
250- cache .wrap_conditional (
251- 0 , is_texan_greeting , self .delayed_return , texan_greeting
252- )
253- for _ in range (6 )
254- }
255-
256- self .reactor .pump ((1 ,))
257-
258- for wrap in positive_wraps :
259- self .assertEqual (
260- texan_greeting ,
261- self .successResultOf (wrap ),
262- "wrap deferred {!r} should have {!r}" .format (wrap , texan_greeting ),
263- )
264-
265- self .assertEqual (
266- texan_greeting ,
267- self .successResultOf (cache .get (0 )),
268- "cache should have the result" ,
269- )
0 commit comments