@@ -144,26 +144,24 @@ struct Item {
144144}
145145
146146async fn example (cosmos_client : CosmosClient ) -> Result <(), Box <dyn std :: error :: Error >> {
147- let container = cosmos_client . database_client (" myDatabase" ). container_client (" myContainer" );
147+ let container = cosmos_client . database_client (" myDatabase" ). container_client (" myContainer" ). await ;
148148
149149 // Read feed ranges for the container (useful for parallelizing change feed processing)
150150 let feed_ranges = container . read_feed_ranges (None ). await ? ;
151151 println! (" Container has {} feed ranges" , feed_ranges . len ());
152152
153153 // Read change feed from the beginning
154- let mut options = QueryChangeFeedOptions :: default ();
155- options . start_from = Some (ChangeFeedStartFrom :: Beginning );
156- options . mode = Some (ChangeFeedMode :: LatestVersion );
157- options . max_item_count = Some (100 );
154+ let options = QueryChangeFeedOptions :: default ()
155+ . with_start_from (ChangeFeedStartFrom :: Beginning )
156+ . with_mode (ChangeFeedMode :: LatestVersion )
157+ . with_max_item_count (100 );
158158
159159 let pager = container . query_items_change_feed :: <Item >(Some (options ))? ;
160160 futures :: pin_mut! (pager );
161161
162162 while let Some (result ) = pager . next (). await {
163- let page = result ? ;
164- for item in page . into_items ()? {
165- println! (" Change feed item: {:?}" , item );
166- }
163+ let item = result ? ;
164+ println! (" Change feed item: {:?}" , item );
167165 }
168166
169167 Ok (())
@@ -178,14 +176,14 @@ You can serialize feed ranges to persist them for later use:
178176use azure_data_cosmos :: {CosmosClient , change_feed :: FeedRange };
179177
180178async fn example (cosmos_client : CosmosClient ) -> Result <(), Box <dyn std :: error :: Error >> {
181- let container = cosmos_client . database_client (" myDatabase" ). container_client (" myContainer" );
179+ let container = cosmos_client . database_client (" myDatabase" ). container_client (" myContainer" ). await ;
182180
183181 // Get feed ranges
184182 let feed_ranges = container . read_feed_ranges (None ). await ? ;
185183
186184 // Serialize for persistence
187185 for range in & feed_ranges {
188- let serialized = range . to_string_representation ();
186+ let serialized = range . to_string_representation ()? ;
189187 // Store `serialized` in your persistence layer
190188 println! (" Serialized feed range: {}" , serialized );
191189
0 commit comments