[BEAM-222] This closes #235
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d5814a38 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d5814a38 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d5814a38 Branch: refs/heads/master Commit: d5814a38d65d8e4c60476122b09a90197b19732b Parents: e953cb0 4e18be8 Author: Luke Cwik <[email protected]> Authored: Mon Apr 25 16:05:19 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Mon Apr 25 16:05:19 2016 -0700 ---------------------------------------------------------------------- .../runners/dataflow/TestCountingSource.java | 34 +++++++----- .../dataflow/TestCountingSourceTest.java | 56 ++++++++++++++++++++ 2 files changed, 78 insertions(+), 12 deletions(-) ----------------------------------------------------------------------
