src/java/org/apache/cassandra/streaming/StreamOutSession.java
/** convenience method for use when testing */
convenience method for use when testing
convenience method for use when testing
void await() throws InterruptedException
    {
        while (streams.containsKey(context))
            Thread.sleep(10);
    }
void await ( ) throws InterruptedException { while ( streams . containsKey ( context ) ) Thread . sleep ( 10 ) ; }
convenience method for use when testing
convenience method for use when testing