@marioortizmanero @ramsayleung it would be very kind of you if you would have a quick look at the approach I have taken. At the moment, the code does not work because I pass a closure to my write_paginate function. The closure gets the current chunk of items, transform them into the payload and executes the endpoint_post method.

However, the self reference to the oauth client (here) does not live long enough to do this. I was unable to fix this issue. May you please give me a hint where I got things wrong and how I could improve on my design? I hope I did formulate my problem adequatly 😅

It would probably be easier if you started with the synchronous version, and then moved on to the asynchronous one. The self borrow issue can be solved by using generics for the Future instead:

pub async fn write_paginate<'a, Item, Writer: 'a, Fut>(
    writer: Writer,
    items: Vec<Item>,
    chunk_size: u32,
) -> String
where
    Writer: Fn(&[Item], u32) -> Fut,
    Fut: futures::Future<Output = Result<String, ClientError>>,
    Item: Display + Debug,

The problem then becomes that you're creating params inside the function, and it's borrowed by the future you're returning. params would drop at the end of the closure, but you haven't awaited the future. Option 1 would be to create params separately. Option 2 is to await the future in the closure, but that would require async closures, which are not stable yet. Option 3 would be to make write_paginate a macro instead. But I think it's a design issue, maybe it can be done with a different approach, also knowing these other things:

• Don't unwrap, propagate the error
• The returned values should be combined. Returning the last one only doesn't make sense for e.g. current_user_saved_albums_contains.
• Maybe different naming? Not sure what write_paginate refers to.

Message to comment on stale PRs. If none provided, will not mark PRs stale