---

pongad · web-flow · commit 93f2edf71565 · 2017-01-24T12:02:34.000+11:00
yaml --- r: 7795 b: refs/heads/tswast-patch-1 c: 302a937 h: refs/heads/master i: 7793: 9046fec 7791: 955d3f9
diff --git a/[refs] b/[refs]
@@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
 refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
 refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
 refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
-refs/heads/tswast-patch-1: 51a9a804df74a1bb8e85c2b2e5f8571ef783ba30
+refs/heads/tswast-patch-1: 302a937773699d3348db0d17ea6a78ebeccbbc52
 refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b
diff --git a/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java b/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Publisher.java
@@ -468,12 +468,6 @@ public boolean failOnFlowControlLimits() {
     return failOnFlowControlLimits;
   }
 
-  /** Retrieves a snapshot of the publisher current {@link PublisherStats statistics}. */
-  public PublisherStats getStats() {
-    // TODO: Implement this.
-    throw new UnsupportedOperationException();
-  }
-
   /**
    * Schedules immediate publishing of any outstanding messages and waits until all are processed.
    *
diff --git a/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java b/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherStats.java
@@ -23,7 +23,7 @@
  * Publisher}.
  */
 @AutoValue
-public abstract class PublisherStats {
+abstract class PublisherStats {
   /** Number of successfully published messages. */
   public abstract long getAckedMessages();
 
diff --git a/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java b/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/Subscriber.java
@@ -365,11 +365,6 @@ public void run() {
     }
   }
 
-  public SubscriberStats getStats() {
-    // TODO: Implement me
-    return null;
-  }
-
   /** Subscription which the subscriber is subscribed to. */
   public String getSubscription() {
     return subscription;
diff --git a/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java b/branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberStats.java
@@ -23,8 +23,8 @@
  * Subscriber}.
  */
 @AutoValue
-public abstract class SubscriberStats {
-  
+abstract class SubscriberStats {
+
   @AutoValue
   //TODO: Finish implementation.
   public abstract static class Stats {}

Original file line number	Diff line number	Diff line change
`@@ -468,12 +468,6 @@ public boolean failOnFlowControlLimits() {`
`468`	`468`	`return failOnFlowControlLimits;`
`469`	`469`	`}`
`470`	`470`
`471`		`- /** Retrieves a snapshot of the publisher current {@link PublisherStats statistics}. */`
`472`		`- public PublisherStats getStats() {`
`473`		`- // TODO: Implement this.`
`474`		`- throw new UnsupportedOperationException();`
`475`		`- }`
`476`		`-`
`477`	`471`	`/**`
`478`	`472`	`* Schedules immediate publishing of any outstanding messages and waits until all are processed.`
`479`	`473`	`*`
Original file line number	Diff line number	Diff line change
`@@ -365,11 +365,6 @@ public void run() {`
`365`	`365`	`}`
`366`	`366`	`}`
`367`	`367`
`368`		`- public SubscriberStats getStats() {`
`369`		`- // TODO: Implement me`
`370`		`- return null;`
`371`		`- }`
`372`		`-`
`373`	`368`	`/** Subscription which the subscriber is subscribed to. */`
`374`	`369`	`public String getSubscription() {`
`375`	`370`	`return subscription;`