Skip to content

Commit bc9a771

Browse files
Merge pull request #440 from ryanseys/no-race-conditions
Remove possibility of race conditions in pubsub reg tests
2 parents ed87968 + 305381f commit bc9a771

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

regression/pubsub.js

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ describe('pubsub', function() {
200200
assert.ifError(err);
201201

202202
subscription.pull({
203-
returnImmediately: true,
203+
returnImmediately: false,
204204
maxResults: 1
205205
}, function(err, msgs) {
206206
assert.ifError(err);
@@ -216,10 +216,11 @@ describe('pubsub', function() {
216216
assert.ifError(err);
217217

218218
subscription.pull({
219-
returnImmediately: true,
219+
returnImmediately: false,
220220
maxResults: 1
221221
}, function(err, msgs) {
222222
assert.ifError(err);
223+
223224
var options = {
224225
ackId: msgs[0].ackId,
225226
seconds: 10
@@ -247,7 +248,7 @@ describe('pubsub', function() {
247248
assert.ifError(err);
248249

249250
subscription.pull({
250-
returnImmediately: true,
251+
returnImmediately: false,
251252
maxResults: 1
252253
}, function(err, msgs) {
253254
assert.ifError(err);
@@ -275,7 +276,7 @@ describe('pubsub', function() {
275276
assert.ifError(err);
276277

277278
subscription.pull({
278-
returnImmediately: true,
279+
returnImmediately: false,
279280
maxResults: 1
280281
}, function(err, msgs) {
281282
assert.ifError(err);
@@ -287,7 +288,7 @@ describe('pubsub', function() {
287288

288289
it('should receive the chosen amount of results', function(done) {
289290
var subscription = topic.subscription(SUB_NAMES[1]);
290-
var opts = { returnImmediately: true, maxResults: 3 };
291+
var opts = { returnImmediately: false, maxResults: 3 };
291292

292293
topic.publish([
293294
{ data: 'hello' },

0 commit comments

Comments
 (0)