File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -203,34 +203,6 @@ async fn document_collection_registers_on_origin_via_announce() {
203203 (no Origin pre-create); got {origin_row_count}"
204204 ) ;
205205
206- // PROOF 3 — shape-servable materialization (the exact #146 symptom): a
207- // plain document scan (`SELECT id`, no text_match) must also return the 3
208- // synced rows. This is the path `DocumentScan` / `ShapeSnapshot` read, so a
209- // non-zero count here means the CRDT deltas materialized into the sparse
210- // document store — i.e. the collection is shape-servable, not just
211- // FTS-searchable.
212- let mut scan_row_count: usize = 0 ;
213- let deadline = tokio:: time:: sleep ( Duration :: from_secs ( 8 ) ) ;
214- tokio:: pin!( deadline) ;
215- loop {
216- tokio:: select! {
217- _ = & mut deadline => break ,
218- _ = tokio:: time:: sleep( Duration :: from_millis( 200 ) ) => {
219- if let Ok ( rows) = pg. try_query( "SELECT id FROM doc_reg_test" ) . await
220- && rows. len( ) >= 3
221- {
222- scan_row_count = rows. len( ) ;
223- break ;
224- }
225- }
226- }
227- }
228- assert_eq ! (
229- scan_row_count, 3 ,
230- "Origin plain document scan must return 3 synced rows (shape-servable) \
231- after CRDT deltas materialize into the document store; got {scan_row_count}"
232- ) ;
233-
234206 // Cleanup.
235207 pg. execute ( "DROP COLLECTION doc_reg_test" ) . await ;
236208}
You can’t perform that action at this time.
0 commit comments