real-cancellable-promise

import { CancellablePromise, Cancellation } from 'real-cancellable-promise'; interface Post { id: number; title: string; body: string; } // Simulate an API call with AbortController for real cancellation function fetchPostWithCancellation(postId: number): CancellablePromise<Post> { const abortController = new AbortController(); const signal = abortController.signal; const promise = fetch(`https://jsonplaceholder.typicode.com/posts/${postId}`, { signal }) .then(response => { if (!response.ok) { throw new Error(`HTTP error! Status: ${response.status}`); } return response.json(); }); return new CancellablePromise( promise, () => { abortController.abort(new Cancellation(`Request for post ${postId} was cancelled.`)); } ); } async function runExample() { console.log('Fetching post 1...'); const cancellableFetch = fetchPostWithCancellation(1); try { // Start the fetch but cancel it after a short delay const timeoutId = setTimeout(() => { console.log('Attempting to cancel fetch for post 1...'); cancellableFetch.cancel(); }, 50); const post = await cancellableFetch; clearTimeout(timeoutId); console.log('Fetched post:', post.title); } catch (error) { if (error instanceof Cancellation) { console.log('Fetch for post 1 was successfully cancelled:', error.message); } else { console.error('Fetch for post 1 failed:', error); } } // Demonstrate a successful fetch console.log('\nFetching post 2...'); const successfulFetch = fetchPostWithCancellation(2); try { const post = await successfulFetch; console.log('Successfully fetched post 2:', post.title); } catch (error) { console.error('Fetch for post 2 failed:', error); } } runExample();