package Ġio . em 2 m . search . mongo Ċ Ċ import Ġio . em 2 m . search . core . model . Field Ċ import Ġorg . junit . Test Ċ Ċ class ĠMongo Sync Dao Streaming Test Ġ: ĠFeatures TestBase () Ġ{ ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` stream Ġall Ġitems `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġresult Ġ= Ġsync Dao . stream Items (). as Sequence (). toList () ĊĠĠĠĠĠĠĠ ĠassertEquals ( 4 6 , Ġresult . size ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` stream Ġall Ġrows `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġresult Ġ= Ġsync Dao . stream Rows ( fields Ġ= ĠlistOf ( Field (" properties . mag ")) ). as Sequence (). toList () ĊĠĠĠĠĠĠĠ ĠassertEquals ( 4 6 , Ġresult . size ) ĊĠĠĠ Ġ} Ċ Ċ } Ċ