---

schmidt-sebastian · pongad · commit 3a6981217b6d · 2018-04-26T17:51:17.000-07:00
yaml --- r: 9335 b: refs/heads/master c: 0097ffa h: refs/heads/master i: 9333: 7d3849b 9331: f4c8d77 9327: 93c9120
diff --git a/[refs] b/[refs]
@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 87b19d669c988a892dc32ee0af6370fcde9dd77e
+refs/heads/master: 0097ffa5fc1e1fe590c1c5e9e2a4b7c458a944d5
 refs/heads/travis: 47e4fee4fd5af9b2a8ce46f23c72ec95f9b195b2
 refs/heads/gh-pages: 1e525ea89a8c2133b947a8f1e3306079d006152d
 refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444
diff --git a/trunk/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreImpl.java b/trunk/google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreImpl.java
@@ -147,13 +147,9 @@ public void onNext(BatchGetDocumentsResponse response) {
 
             numResponses++;
             if (numResponses == 1) {
-              tracer
-                  .getCurrentSpan()
-                  .addAnnotation("Firestore.BatchGet: First response");
+              tracer.getCurrentSpan().addAnnotation("Firestore.BatchGet: First response");
             } else if (numResponses % 100 == 0) {
-              tracer
-                  .getCurrentSpan()
-                  .addAnnotation("Firestore.BatchGet: Received 100 responses");
+              tracer.getCurrentSpan().addAnnotation("Firestore.BatchGet: Received 100 responses");
             }
 
             switch (response.getResultCase()) {
diff --git a/trunk/google-cloud-firestore/src/main/java/com/google/cloud/firestore/Query.java b/trunk/google-cloud-firestore/src/main/java/com/google/cloud/firestore/Query.java
@@ -924,7 +924,8 @@ private void stream(
       request.setTransaction(transactionId);
     }
 
-    Tracing.getTracer().getCurrentSpan()
+    Tracing.getTracer()
+        .getCurrentSpan()
         .addAnnotation(
             "Firestore.Query: Start",
             ImmutableMap.of(
@@ -940,13 +941,13 @@ private void stream(
           public void onNext(RunQueryResponse response) {
             if (!firstResponse) {
               firstResponse = true;
-              Tracing.getTracer().getCurrentSpan()
-                  .addAnnotation("Firestore.Query: First response");
+              Tracing.getTracer().getCurrentSpan().addAnnotation("Firestore.Query: First response");
             }
             if (response.hasDocument()) {
               numDocuments++;
               if (numDocuments % 100 == 0) {
-                Tracing.getTracer().getCurrentSpan()
+                Tracing.getTracer()
+                    .getCurrentSpan()
                     .addAnnotation("Firestore.Query: Received 100 documents");
               }
               Document document = response.getDocument();
@@ -970,12 +971,12 @@ public void onError(Throwable throwable) {
 
           @Override
           public void onCompleted() {
-            Tracing.getTracer().getCurrentSpan()
+            Tracing.getTracer()
+                .getCurrentSpan()
                 .addAnnotation(
                     "Firestore.Query: Completed",
                     ImmutableMap.of(
-                        "numDocuments",
-                        AttributeValue.longAttributeValue(numDocuments)));
+                        "numDocuments", AttributeValue.longAttributeValue(numDocuments)));
             documentObserver.onCompleted(readTime);
           }
         };
diff --git a/trunk/google-cloud-firestore/src/main/java/com/google/cloud/firestore/UpdateBuilder.java b/trunk/google-cloud-firestore/src/main/java/com/google/cloud/firestore/UpdateBuilder.java
@@ -578,9 +578,11 @@ private T performDelete(
 
   /** Commit the current batch. */
   ApiFuture<List<WriteResult>> commit(@Nullable ByteString transactionId) {
-    Tracing.getTracer().getCurrentSpan().addAnnotation(
-        "CloudFirestore.Commit",
-        ImmutableMap.of("numDocuments", AttributeValue.longAttributeValue(mutations.size())));
+    Tracing.getTracer()
+        .getCurrentSpan()
+        .addAnnotation(
+            "CloudFirestore.Commit",
+            ImmutableMap.of("numDocuments", AttributeValue.longAttributeValue(mutations.size())));
 
     final CommitRequest.Builder request = CommitRequest.newBuilder();
     request.setDatabase(firestore.getDatabaseName());
diff --git a/trunk/google-cloud-firestore/src/test/java/com/google/cloud/firestore/QueryTest.java b/trunk/google-cloud-firestore/src/test/java/com/google/cloud/firestore/QueryTest.java
@@ -536,16 +536,16 @@ public void getResult() throws Exception {
     Iterator<DocumentChange> changeIterator = result.getDocumentChanges().iterator();
 
     DocumentChange documentChange = changeIterator.next();
-    assertEquals("doc1",documentChange.getDocument().getId());
-    assertEquals(DocumentChange.Type.ADDED,documentChange.getType());
-    assertEquals(-1,documentChange.getOldIndex());
-    assertEquals(0,documentChange.getNewIndex());
+    assertEquals("doc1", documentChange.getDocument().getId());
+    assertEquals(DocumentChange.Type.ADDED, documentChange.getType());
+    assertEquals(-1, documentChange.getOldIndex());
+    assertEquals(0, documentChange.getNewIndex());
 
     documentChange = changeIterator.next();
-    assertEquals("doc2",documentChange.getDocument().getId());
-    assertEquals(DocumentChange.Type.ADDED,documentChange.getType());
-    assertEquals(-1,documentChange.getOldIndex());
-    assertEquals(1,documentChange.getNewIndex());
+    assertEquals("doc2", documentChange.getDocument().getId());
+    assertEquals(DocumentChange.Type.ADDED, documentChange.getType());
+    assertEquals(-1, documentChange.getOldIndex());
+    assertEquals(1, documentChange.getNewIndex());
 
     assertFalse(changeIterator.hasNext());
 
