Repository: incubator-beam Updated Branches: refs/heads/master 9c3e3e7a3 -> e82c5d224
Closes #1190 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e82c5d22 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e82c5d22 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e82c5d22 Branch: refs/heads/master Commit: e82c5d2246372041ee7cc362363b2ac959a6bd4a Parents: 9c3e3e7 cd454aa Author: Dan Halperin <[email protected]> Authored: Fri Oct 28 11:32:06 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Fri Oct 28 11:32:06 2016 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/PubsubUnboundedSource.java | 123 +++++++++++++------ .../apache/beam/sdk/util/PubsubTestClient.java | 32 +++++ .../beam/sdk/io/PubsubUnboundedSourceTest.java | 79 ++++++++++++ 3 files changed, 199 insertions(+), 35 deletions(-) ----------------------------------------------------------------------
