Wie kann ich Changefeeds in RethinkDB abbestellen? Wenn Änderungen über

Question

Cursor changeCursor = r.table("users").changes().run(conn); 
for (Object change : changeCursor) { 
    System.out.println(change); 
} 

sind, muss ich nur Änderungen einmal wissen. Ich weiß, "changeCursor.close()" kann Feeds stoppen. Das Problem ist, wie kann ich die Größe der Änderungen dieses Mal wissen !!

Wenn drei Benutzer hinzugefügt wurden, führen "System.out.println (ändern)" die Zeiten aus. Wenn nur ein Benutzer hinzugefügt wurde, wird "System.out.println (ändern)" einmal ausgeführt. Dann muss ich Changefeeds in RethinkDB abbestellen.

changeCursor.toList(); 
changeCursor.iterator(); 

Nichts tun!

changeCursor.hasNext(); 

Alaways wahr!

Ich kenne die Anzahl der Änderungen nicht. Ich weiß nicht, wann ich die Methode changeCursor.close() ausführen soll.

Answer 1

Ich bin nicht wirklich sicher, was Sie fragen. Es scheint, dass Sie sofort die erste Änderung erhalten möchten und schließen Sie sie dann.

Sie können mit JavaScrip Fahrer so etwas tun:

var r  = require('rethinkdb') 

r.connect({ 
    host: 'localhost', 
    port: 28015, 
}) 
.then(function(conn) { 
    return r.table('users').changes().run(conn) 
}) 
.then(function(cursor) { 
    cursor.next() 
    .then(function(doc) { 
     console.log(doc) 
     //Ok, now right after we get the first doc, we will close the cursor 
     cursor.close() 
     // if we want, we can also close connection 
     // cursor.close().then(conn.close()) 
    }) 
})