This closes #967
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3879db03 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3879db03 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3879db03 Branch: refs/heads/master Commit: 3879db03657dd9331977313d5f3ab30d5f163b60 Parents: db47c63 f3f2a97 Author: Maximilian Michels <m...@apache.org> Authored: Tue Sep 27 11:15:55 2016 +0200 Committer: Maximilian Michels <m...@apache.org> Committed: Wed Sep 28 11:16:37 2016 +0200 ---------------------------------------------------------------------- .../streaming/io/UnboundedSourceWrapper.java | 96 ++++++++++++++++---- .../streaming/UnboundedSourceWrapperTest.java | 10 ++ 2 files changed, 88 insertions(+), 18 deletions(-) ----------------------------------------------------------------------
