1   /*
2       This file is part of quExec.
3   
4       quExec is free software; you can redistribute it and/or modify
5       it under the terms of the GNU Lesser General Public License as published by
6       the Free Software Foundation; either version 2 of the License, or
7       (at your option) any later version.
8   
9       quExec is distributed in the hope that it will be useful,
10      but WITHOUT ANY WARRANTY; without even the implied warranty of
11      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12      GNU Lesser General Public License for more details.
13  
14      You should have received a copy of the GNU Lesser General Public License
15      along with quExec; if not, write to the Free Software
16      Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
17  */
18  
19  package net.sourceforge.quexec.packet.chars.stream;
20  
21  import static org.junit.Assert.assertNull;
22  import static org.junit.Assert.assertTrue;
23  
24  import org.apache.commons.logging.Log;
25  import org.apache.commons.logging.LogFactory;
26  
27  public class StreamTestUtils {
28  	
29  	private static final Log log = LogFactory.getLog(StreamTestUtils.class);
30  
31  	public static void checkStreamFinished(CharPacketInputStream stream)
32  	throws InterruptedException {
33  		assertNull(stream.tryReadPacket());
34  		while (!stream.isFinished()) {
35  			log.debug("stream not yet finished. waiting...");
36  			Thread.sleep(100);
37  		}
38  		assertTrue(stream.isFinished());
39  	}
40  
41  }