googleapis
diff --git a/‎google-cloud-logging/clirr-ignored-differences.xml‎
Lines changed: 10 additions & 0 deletions b/‎google-cloud-logging/clirr-ignored-differences.xml‎
Lines changed: 10 additions & 0 deletions
diff --git a/‎google-cloud-logging/src/main/java/com/google/cloud/logging/LogEntryIterator.java‎
Lines changed: 47 additions & 0 deletions b/‎google-cloud-logging/src/main/java/com/google/cloud/logging/LogEntryIterator.java‎
Lines changed: 47 additions & 0 deletions
diff --git a/‎google-cloud-logging/src/main/java/com/google/cloud/logging/LogEntryServerStream.java‎
Lines changed: 64 additions & 0 deletions b/‎google-cloud-logging/src/main/java/com/google/cloud/logging/LogEntryServerStream.java‎
Lines changed: 64 additions & 0 deletions
@@ -8,10 +8,20 @@
         <className>com/google/cloud/logging/Logging</className>
         <method>* listLogs*(com.google.cloud.logging.Logging$ListOption[])</method>
     </difference>
+    <difference>
+        <differenceType>7012</differenceType>
+        <className>com/google/cloud/logging/Logging</className>
+        <method>com.google.cloud.logging.LogEntryServerStream tailLogEntries(com.google.cloud.logging.Logging$TailOption[])</method>
+    </difference>
     <!-- Added methods to com.google.cloud.logging.spi.v2.LoggingRpc interface with implementation in GrpcLoggingRpc is always okay -->
     <difference>
         <differenceType>7012</differenceType>
         <className>com/google/cloud/logging/spi/v2/LoggingRpc</className>
         <method>* listLogs(com.google.logging.v2.ListLogsRequest)</method>
     </difference>
+    <difference>
+        <differenceType>7012</differenceType>
+        <className>com/google/cloud/logging/spi/v2/LoggingRpc</className>
+        <method>com.google.api.gax.rpc.BidiStream getTailLogEntriesStream()</method>
+    </difference>
 </differences>
@@ -0,0 +1,47 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.logging;
+
+import com.google.common.collect.Lists;
+import com.google.logging.v2.TailLogEntriesResponse;
+import java.util.Iterator;
+import java.util.LinkedList;
+
+public class LogEntryIterator implements Iterator<LogEntry> {
+  private final Iterator<TailLogEntriesResponse> streamIterator;
+  private final LinkedList<LogEntry> buffer = new LinkedList<>();
+
+  LogEntryIterator(Iterator<TailLogEntriesResponse> streamIterator) {
+    this.streamIterator = streamIterator;
+  }
+
+  /** {@inheritDoc} */
+  @Override
+  public boolean hasNext() {
+    return !buffer.isEmpty() || streamIterator.hasNext();
+  }
+
+  /** {@inheritDoc} */
+  @Override
+  public LogEntry next() {
+    if (buffer.isEmpty()) {
+      TailLogEntriesResponse response = streamIterator.next();
+      buffer.addAll(Lists.transform(response.getEntriesList(), LogEntry.FROM_PB_FUNCTION));
+    }
+    return buffer.pop();
+  }
+}
@@ -0,0 +1,64 @@
+/*
+ * Copyright 2021 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.cloud.logging;
+
+import com.google.api.gax.rpc.BidiStream;
+import com.google.common.collect.Lists;
+import com.google.logging.v2.TailLogEntriesRequest;
+import com.google.logging.v2.TailLogEntriesResponse;
+import java.util.Iterator;
+
+public class LogEntryServerStream implements Iterable<LogEntry> {
+  private final BidiStream<TailLogEntriesRequest, TailLogEntriesResponse> serverStream;
+
+  LogEntryServerStream(BidiStream<TailLogEntriesRequest, TailLogEntriesResponse> serverStream) {
+    this.serverStream = serverStream;
+  }
+
+  /** {@inheritDoc} */
+  @Override
+  public Iterator<LogEntry> iterator() {
+    return new LogEntryIterator(serverStream.iterator());
+  }
+
+  public BidiStream<TailLogEntriesRequest, TailLogEntriesResponse> getInternalStream() {
+    return serverStream;
+  }
+
+  public java.util.List<LogEntry> convert(TailLogEntriesResponse resp) {
+    return Lists.transform(resp.getEntriesList(), LogEntry.FROM_PB_FUNCTION);
+  }
+
+  /**
+   * Returns true if the next call to the iterator's hasNext() or next() is guaranteed to be
+   * nonblocking.
+   *
+   * @return If the call on any of the iterator's methods is guaranteed to be nonblocking.
+   */
+  public boolean isReceiveReady() {
+    return serverStream.isReceiveReady();
+  }
+
+  /**
+   * Cleanly cancels a partially consumed stream. The associated iterator will return false for the
+   * hasNext() in the next iteration. This maintains the contract that an observed true from
+   * hasNext() will yield an item in next(), but afterwards will return false.
+   */
+  public void cancel() {
+    serverStream.cancel();
+  }
+}