Repository: beam Updated Branches: refs/heads/master a2ff162c9 -> 1bd17d1b9
This closes #3888 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1bd17d1b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1bd17d1b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1bd17d1b Branch: refs/heads/master Commit: 1bd17d1b95a6b27331626fa9bdbaa723969b710d Parents: a2ff162 2e27526 Author: Thomas Groh <tg...@google.com> Authored: Mon Sep 25 13:38:00 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Mon Sep 25 13:38:00 2017 -0700 ---------------------------------------------------------------------- .../io/gcp/pubsub/PubsubUnboundedSource.java | 18 ++++--- .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 55 ++++++++++++++++++++ 2 files changed, 67 insertions(+), 6 deletions(-) ----------------------------------------------------------------------
