diff options
| author | Ryan LeCompte <lecompte@gmail.com> | 2013-01-12 09:18:00 -0800 |
|---|---|---|
| committer | Ryan LeCompte <lecompte@gmail.com> | 2013-01-12 09:18:00 -0800 |
| commit | ea20ae661888d871f70d5ed322cfe924c5a31dba (patch) | |
| tree | 76771fd8444bed9eeff693bf2975278d6e05f94f /core | |
| parent | 2c77eeebb66a3d1337d45b5001be2b48724f9fd5 (diff) | |
| download | spark-ea20ae661888d871f70d5ed322cfe924c5a31dba.tar.gz spark-ea20ae661888d871f70d5ed322cfe924c5a31dba.tar.bz2 spark-ea20ae661888d871f70d5ed322cfe924c5a31dba.zip | |
add one extra test
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/test/scala/spark/util/RateLimitedOutputStreamSuite.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/core/src/test/scala/spark/util/RateLimitedOutputStreamSuite.scala b/core/src/test/scala/spark/util/RateLimitedOutputStreamSuite.scala index b392075482..794063fb6d 100644 --- a/core/src/test/scala/spark/util/RateLimitedOutputStreamSuite.scala +++ b/core/src/test/scala/spark/util/RateLimitedOutputStreamSuite.scala @@ -18,5 +18,6 @@ class RateLimitedOutputStreamSuite extends FunSuite { val stream = new RateLimitedOutputStream(underlying, 10000) val elapsedNs = benchmark { stream.write(data.getBytes("UTF-8")) } assert(SECONDS.convert(elapsedNs, NANOSECONDS) == 4) + assert(underlying.toString("UTF-8") == data) } } |