Repository: beam Updated Branches: refs/heads/master 65ffd6c64 -> 5eb78ae8a
This closes #2368 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5eb78ae8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5eb78ae8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5eb78ae8 Branch: refs/heads/master Commit: 5eb78ae8a9300e555b7701f191dd3af490a4e77e Parents: 65ffd6c 9c6c32b Author: Thomas Groh <[email protected]> Authored: Tue Apr 4 15:39:33 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Tue Apr 4 15:39:33 2017 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/PubsubUnboundedSource.java | 74 ++++++++++++++------ .../beam/sdk/io/PubsubUnboundedSourceTest.java | 13 ++++ 2 files changed, 65 insertions(+), 22 deletions(-) ----------------------------------------------------------------------
