Uploaded image for project: 'Ruby Driver'
  1. Ruby Driver
  2. RUBY-1275

Add pipeline stage to ChangeStreams example for Docs

    • Type: Icon: Task Task
    • Resolution: Fixed
    • Priority: Icon: Minor - P4 Minor - P4
    • 2.5.1
    • Affects Version/s: None
    • Component/s: None
    • None
    • 1

      In a previous ticket DRIVERS-414, included Example 1-3. This ticket is to add the Example 4 sections to the existing example :

      // Start Changestream Example 1
      
      MongoCursor<Document> cursor = inventory.watch().iterator();
      Document next = cursor.next();
      
      // End Changestream Example 1
      
      // Start Changestream Example 2
      
      MongoCursor<Document> cursor = 
      inventory.watch().fullDocument(FullDocument.UPDATE_LOOKUP).iterator();
      Document next = cursor.next();
      
      // End Changestream Example 2
      
      // Start Changestream Example 3
      
      Document resumeToken = next.get("_id", Document.class);
      MongoCursor<Document> cursor = inventory.watch().resumeAfter(resumeToken).iterator();
      cursor.next();
      
      // End Changestream Example 3
      
      // Start Changestream Example 4
      
      List<Bson> pipeline = singletonList(Aggregates.match(Filters.or(
         Document.parse("{'fullDocument.username': 'alice'}"),
         Filters.in("operationType", asList("delete")))));
      
      // End Changestream Example 4
      

            Assignee:
            emily.stolfo Emily Stolfo
            Reporter:
            rathi.gnanasekaran Rathi Gnanasekaran
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated:
              Resolved: