diff options
| author |  buchgr <buchgr@google.com> | 2018-06-29 13:00:36 -0700 |
|---|---|---|
| committer |  Copybara-Service <copybara-piper@google.com> | 2018-06-29 13:02:14 -0700 |
| commit | d3f7f7ae1369834b5f81d62474d20541d8b1a918 (patch) | |
| tree | 98fc8fba21092224e0950f5e27556c3ae07b19e2 /src/test | |
| parent | 6e92f97f2953890055c6d724ce2aa6b3c0fca4dc (diff) | |
bep: Make the BuildEventArtifactUploader async.
This changes the BuildEventArtifactUploader to an async interface,
thereby no longer potentially delaying event delivery over the
eventbus. Additionally, the BES transport is changed to start
uploading local files immediately as the events are delivered.
RELNOTES: None
PiperOrigin-RevId: 202694121
Diffstat (limited to 'src/test')
| -rw-r--r-- | src/test/java/com/google/devtools/build/lib/buildeventstream/BuildEventArtifactUploaderMapTest.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/test/java/com/google/devtools/build/lib/buildeventstream/BuildEventArtifactUploaderMapTest.java b/src/test/java/com/google/devtools/build/lib/buildeventstream/BuildEventArtifactUploaderMapTest.java index 095c42dbda..241d9db895 100644 --- a/src/test/java/com/google/devtools/build/lib/buildeventstream/BuildEventArtifactUploaderMapTest.java +++ b/src/test/java/com/google/devtools/build/lib/buildeventstream/BuildEventArtifactUploaderMapTest.java @@ -15,6 +15,8 @@ package com.google.devtools.build.lib.buildeventstream; import static com.google.common.truth.Truth.assertThat; +import com.google.common.util.concurrent.Futures; +import com.google.common.util.concurrent.ListenableFuture; import com.google.devtools.build.lib.vfs.Path; import java.util.Set; import org.junit.Before; @@ -33,8 +35,8 @@ public final class BuildEventArtifactUploaderMapTest { noConversionUploader = new BuildEventArtifactUploader() { @Override - public PathConverter upload(Set<Path> files) { - return PathConverter.NO_CONVERSION; + public ListenableFuture<PathConverter> upload(Set<Path> files) { + return Futures.immediateFuture(PathConverter.NO_CONVERSION); } }; uploader = |