gistfile1.txt

protocol SearchService {
  
    // stream results directly to view model 
    var searchResults: AsyncStream<[User]>
  
    func search(query: String) async throws     

    // cursor-based pagination
    func nextPage(query: String, after user: User) -> async throws
} 


final class SearchServiceImpl: SearchService {
    
    private var searchTask: Task<Void, Error>?
    
    func search(query: String) async throws {
        searchTask?.cancel()
        searchTask = {
            try Task.checkCancellation()
            // perform search network request 
        }
    }
}