@@ -360,6 +360,10 @@ describe("Readme query samples", function () {
360360 // ...
361361 } ) ;
362362
363+ userStream . on ( "end" , ( ) => {
364+ assert . ok ( result . length ) ;
365+ } ) ;
366+
363367 await new Promise ( ( resolve , reject ) => {
364368 stream . finished ( userStream , err => {
365369 err ? reject ( err ) : resolve ( ) ;
@@ -369,12 +373,14 @@ describe("Readme query samples", function () {
369373
370374 it ( "can stream query and get stats" , async ( ) => {
371375 let stats : StreamQueryStatistics ;
376+ const items = [ ] ;
372377 query = session . query ( { collection : "users" } )
373378 . whereGreaterThan ( "age" , 29 ) ;
374379 const queryStream = await session . advanced . stream ( query , _ => stats = _ ) ;
375380
376381 queryStream . on ( "data" , user => {
377382 print ( user ) ;
383+ items . push ( user ) ;
378384 // ...
379385 } ) ;
380386
@@ -386,6 +392,7 @@ describe("Readme query samples", function () {
386392 await new Promise ( ( resolve , reject ) => {
387393 queryStream . on ( "end" , ( ) => {
388394 try {
395+ assert . ok ( items . length ) ;
389396 assert . ok ( stats ) ;
390397 assert . strictEqual ( stats . totalResults , 1 ) ;
391398 assert . strictEqual ( stats . indexName , "Auto/users/Byage" ) ;
@@ -401,6 +408,33 @@ describe("Readme query samples", function () {
401408
402409 } ) ;
403410
411+ describe ( "with revisions set up" , function ( ) {
412+
413+ beforeEach ( async ( ) => testContext . setupRevisions ( store , false , 5 ) ) ;
414+
415+ it ( "can get revisions" , async ( ) => {
416+
417+ const session = store . openSession ( ) ;
418+
419+ const user = {
420+ name : "Marcin" ,
421+ age : 30 ,
422+ pet : "users/4"
423+ } ;
424+
425+ await session . store ( user , "users/1" ) ;
426+ await session . saveChanges ( ) ;
427+
428+ user . name = "Roman" ;
429+ user . age = 40 ;
430+ await session . saveChanges ( ) ;
431+
432+ const revisions = await session . advanced . revisions . getFor ( "users/1" ) ;
433+ assert . strictEqual ( revisions . length , 2 ) ;
434+ } ) ;
435+
436+ } ) ;
437+
404438 async function prepareUserDataSet ( store : IDocumentStore ) {
405439 const users = [
406440 new User ( {
0 commit comments