@@ -71,10 +71,7 @@ async fn test_back_pagination() {
71
71
. await ;
72
72
73
73
let paginate = async {
74
- timeline
75
- . live_paginate_backwards_with_options ( PaginationOptions :: simple_request ( 10 ) )
76
- . await
77
- . unwrap ( ) ;
74
+ timeline. live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) ) . await . unwrap ( ) ;
78
75
server. reset ( ) . await ;
79
76
} ;
80
77
let observe_paginating = async {
@@ -133,10 +130,7 @@ async fn test_back_pagination() {
133
130
. mount ( & server)
134
131
. await ;
135
132
136
- timeline
137
- . live_paginate_backwards_with_options ( PaginationOptions :: simple_request ( 10 ) )
138
- . await
139
- . unwrap ( ) ;
133
+ timeline. live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) ) . await . unwrap ( ) ;
140
134
assert_next_eq ! ( back_pagination_status, PaginationStatus :: TimelineEndReached ) ;
141
135
}
142
136
@@ -201,10 +195,7 @@ async fn test_back_pagination_highlighted() {
201
195
. mount ( & server)
202
196
. await ;
203
197
204
- timeline
205
- . live_paginate_backwards_with_options ( PaginationOptions :: simple_request ( 10 ) )
206
- . await
207
- . unwrap ( ) ;
198
+ timeline. live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) ) . await . unwrap ( ) ;
208
199
server. reset ( ) . await ;
209
200
210
201
let first = assert_next_matches ! (
@@ -272,9 +263,7 @@ async fn test_wait_for_token() {
272
263
273
264
let paginate = async {
274
265
timeline
275
- . live_paginate_backwards_with_options (
276
- PaginationOptions :: simple_request ( 10 ) . wait_for_token ( ) ,
277
- )
266
+ . live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) . wait_for_token ( ) )
278
267
. await
279
268
. unwrap ( ) ;
280
269
} ;
@@ -339,16 +328,10 @@ async fn test_dedup() {
339
328
340
329
// If I try to paginate twice at the same time,
341
330
let paginate_1 = async {
342
- timeline
343
- . live_paginate_backwards_with_options ( PaginationOptions :: simple_request ( 10 ) )
344
- . await
345
- . unwrap ( ) ;
331
+ timeline. live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) ) . await . unwrap ( ) ;
346
332
} ;
347
333
let paginate_2 = async {
348
- timeline
349
- . live_paginate_backwards_with_options ( PaginationOptions :: simple_request ( 10 ) )
350
- . await
351
- . unwrap ( ) ;
334
+ timeline. live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) ) . await . unwrap ( ) ;
352
335
} ;
353
336
timeout ( Duration :: from_secs ( 5 ) , join ( paginate_1, paginate_2) ) . await . unwrap ( ) ;
354
337
@@ -439,9 +422,7 @@ async fn test_timeline_reset_while_paginating() {
439
422
440
423
let paginate = async {
441
424
timeline
442
- . live_paginate_backwards_with_options (
443
- PaginationOptions :: simple_request ( 10 ) . wait_for_token ( ) ,
444
- )
425
+ . live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) . wait_for_token ( ) )
445
426
. await
446
427
. unwrap ( ) ;
447
428
} ;
@@ -579,10 +560,7 @@ async fn test_empty_chunk() {
579
560
. await ;
580
561
581
562
let paginate = async {
582
- timeline
583
- . live_paginate_backwards_with_options ( PaginationOptions :: simple_request ( 10 ) )
584
- . await
585
- . unwrap ( ) ;
563
+ timeline. live_paginate_backwards ( PaginationOptions :: simple_request ( 10 ) ) . await . unwrap ( ) ;
586
564
server. reset ( ) . await ;
587
565
} ;
588
566
let observe_paginating = async {
@@ -681,10 +659,7 @@ async fn test_until_num_items_with_empty_chunk() {
681
659
. await ;
682
660
683
661
let paginate = async {
684
- timeline
685
- . live_paginate_backwards_with_options ( PaginationOptions :: until_num_items ( 4 , 4 ) )
686
- . await
687
- . unwrap ( ) ;
662
+ timeline. live_paginate_backwards ( PaginationOptions :: until_num_items ( 4 , 4 ) ) . await . unwrap ( ) ;
688
663
server. reset ( ) . await ;
689
664
} ;
690
665
let observe_paginating = async {
0 commit comments