Repository: incubator-beam Updated Branches: refs/heads/master ae46f9a87 -> ccb8b82c8
Closes #1696 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ccb8b82c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ccb8b82c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ccb8b82c Branch: refs/heads/master Commit: ccb8b82c868d16d65de57cbdcaff119a33785bbd Parents: ae46f9a 8cb1ed5 Author: Dan Halperin <[email protected]> Authored: Tue Dec 27 09:35:47 2016 -0800 Committer: Dan Halperin <[email protected]> Committed: Tue Dec 27 09:35:47 2016 -0800 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/PubsubIO.java | 24 ++++++++++++-------- .../org/apache/beam/sdk/io/PubsubIOTest.java | 16 +++++++++++++ 2 files changed, 30 insertions(+), 10 deletions(-) ----------------------------------------------------------------------
