TFJ-397 SiteStreamTest#testStream was broken as SiteStreamImpl now ha…

…ndles listners asynchronously
Twitter4J · Dec 7, 2010 · 52fc9b7 · 52fc9b7
1 parent 15bfe13
commit 52fc9b7
Showing 1 changed file with 15 additions and 3 deletions.
diff --git a/twitter4j-core/src/test/java/twitter4j/SiteStreamTest.java b/twitter4j-core/src/test/java/twitter4j/SiteStreamTest.java
@@ -52,13 +52,25 @@ public void testStream() throws Exception {
         listeners[0] = this;
         received.clear();
         siteStream.next(listeners);
-        assertEquals(6358482, received.get(0)[0]);
+        synchronized(this){
+            this.wait(200);
+        }
+        assertEquals("onfriendlist", received.get(0)[0]);
+        assertEquals(6358482, received.get(0)[1]);
         received.clear();
         siteStream.next(listeners);
-        assertEquals(new Integer(6358481), received.get(0)[0]);
+        synchronized(this){
+            this.wait(200);
+        }
+        assertEquals("onfriendlist", received.get(0)[0]);
+        assertEquals(new Integer(6358481), received.get(0)[1]);
         received.clear();
         siteStream.next(listeners);
-        assertEquals(new Integer(4933401), received.get(0)[0]);
+        synchronized(this){
+            this.wait(200);
+        }
+        assertEquals("onfriendlist", received.get(0)[0]);
+        assertEquals(new Integer(4933401), received.get(0)[1]);
     }
 
     public void testSiteStream() throws Exception {