Skip to content

Commit 1455a3a

Browse files
authored
Corrected successSubscriber to documentSubscriber for two await calls in reactive QuickTour (#962)
1 parent 9495ba6 commit 1455a3a

File tree

1 file changed

+2
-2
lines changed
  • driver-reactive-streams/src/examples/reactivestreams/tour

1 file changed

+2
-2
lines changed

driver-reactive-streams/src/examples/reactivestreams/tour/QuickTour.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -127,12 +127,12 @@ public static void main(final String[] args) {
127127
// now use a range query to get a larger subset
128128
documentSubscriber = new PrintDocumentSubscriber();
129129
collection.find(gt("i", 50)).subscribe(documentSubscriber);
130-
successSubscriber.await();
130+
documentSubscriber.await();
131131

132132
// range query with multiple constraints
133133
documentSubscriber = new PrintDocumentSubscriber();
134134
collection.find(and(gt("i", 50), lte("i", 100))).subscribe(documentSubscriber);
135-
successSubscriber.await();
135+
documentSubscriber.await();
136136

137137
// Sorting
138138
documentSubscriber = new PrintDocumentSubscriber();

0 commit comments

Comments
 (0)