GoogleCloudPlatform / google-cloud-java / 4154

80%

master: 72%

Pull #2212

travis-ci

pubsub: enable streaming pull

Moving this to a branch.
If nothing else, we should perf test this before
declaring it release-ready.

This commit re-enables streaming pull.
Unlike previous implementation,
it does not fall back to polling if streaming is unavailable,
since the streaming pull endpoint should be working
by the time this is released.

This commit fixes a bug deadline modification code.
Previously we record an Instant we receive a message,
then call Instant::getNano to get the time in nanoseconds.
This is incorrect since getNano returns the nanosecond
from the beginning of that second, not since an epoch.
The fix is to simply save the time since epoch instead of Instant.

This commit also slightly changes how errors are logged,
so that errors that occur after the service is being shut down
don't spam the console.

49 of 49 new or added lines in 3 files covered. (100.0%)

19670 of 24225 relevant lines covered (81.2%)

57900.06 hits per line