git-svn-id: http://jclouds.googlecode.com/svn/trunk@1445 3d8758e0-26b5-11de-8745-db77d3ebf521
This commit is contained in:
adrian.f.cole 2009-06-18 01:52:28 +00:00
parent 55f39fc7de
commit 852374b35a
1 changed files with 5 additions and 1 deletions

View File

@ -55,8 +55,10 @@ public class S3InputStreamMapIntegrationTest extends BaseS3MapIntegrationTest<In
@Override @Override
@Test(groups = { "integration", "live" }) @Test(groups = { "integration", "live" })
public void testValues() throws IOException { public void testValues() throws IOException, InterruptedException {
map.putAll(this.fiveInputs); map.putAll(this.fiveInputs);
// this will cause us to block until the bucket updates.
assertEventuallyKeySize(5);
Collection<InputStream> values = map.values(); Collection<InputStream> values = map.values();
assertEquals(values.size(), 5); assertEquals(values.size(), 5);
Set<String> valuesAsString = new HashSet<String>(); Set<String> valuesAsString = new HashSet<String>();
@ -83,6 +85,8 @@ public class S3InputStreamMapIntegrationTest extends BaseS3MapIntegrationTest<In
@Test(groups = { "integration", "live" }) @Test(groups = { "integration", "live" })
public void testEntrySet() throws IOException, InterruptedException { public void testEntrySet() throws IOException, InterruptedException {
map.putAllStrings(this.fiveStrings); map.putAllStrings(this.fiveStrings);
// this will cause us to block until the bucket updates.
assertEventuallyKeySize(5);
Set<Entry<String, InputStream>> entries = map.entrySet(); Set<Entry<String, InputStream>> entries = map.entrySet();
assertEquals(entries.size(), 5); assertEquals(entries.size(), 5);
for (Entry<String, InputStream> entry : entries) { for (Entry<String, InputStream> entry : entries) {