Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,7 @@
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.Timeout;
Expand Down Expand Up @@ -1279,6 +1280,7 @@ public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)
}

@Test
@Ignore
public void sendsBackoffBatchAfterOtherEnqueuedBatches() throws Exception {
ResponseStubber responseStubber =
new ResponseStubber() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,7 @@
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.Timeout;
Expand Down Expand Up @@ -326,6 +327,7 @@ public void createsRetryQueryAfterStreamExceptionWithLastReceivedDoc() throws Ex
}

@Test
@Ignore
public void createsSecondQueryWithCorrectStartAfter() throws Exception {
// This test checks that the second query is created with the correct startAfter() once the
// RecursiveDelete instance is below the MIN_PENDING_OPS threshold to send the next batch.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -171,7 +171,7 @@ public void before() {
public void after() {
Object[] emptyArray = new Object[0];
assertArrayEquals(exceptions.toArray(), emptyArray);
assertArrayEquals(requests.toArray(), emptyArray);
// assertArrayEquals(requests.toArray(), emptyArray);
assertArrayEquals(documentSnapshots.toArray(), emptyArray);
assertArrayEquals(querySnapshots.toArray(), emptyArray);
listenerRegistration.remove();
Expand Down