Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(275)

Side by Side Diff: lib/src/pubsub_impl.dart

Issue 1185613002: Widen constraints to pick up latest googleapis versions. (Closed) Base URL: https://github.com/dart-lang/gcloud@master
Patch Set: Created 5 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « no previous file | pubspec.yaml » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 part of gcloud.pubsub; 5 part of gcloud.pubsub;
6 6
7 class _PubSubImpl implements PubSub { 7 class _PubSubImpl implements PubSub {
8 final http.Client _client; 8 final http.Client _client;
9 final String project; 9 final String project;
10 final pubsub.PubsubApi _api; 10 final pubsub.PubsubApi _api;
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after
100 ..maxMessages = 1 100 ..maxMessages = 1
101 ..returnImmediately = returnImmediately; 101 ..returnImmediately = returnImmediately;
102 return _api.projects.subscriptions.pull(request, subscription); 102 return _api.projects.subscriptions.pull(request, subscription);
103 } 103 }
104 104
105 Future _ack(String ackId, String subscription) { 105 Future _ack(String ackId, String subscription) {
106 var request = new pubsub.AcknowledgeRequest() 106 var request = new pubsub.AcknowledgeRequest()
107 ..ackIds = [ ackId ]; 107 ..ackIds = [ ackId ];
108 // The Pub/Sub acknowledge API returns an instance of Empty. 108 // The Pub/Sub acknowledge API returns an instance of Empty.
109 return _api.projects.subscriptions.acknowledge( 109 return _api.projects.subscriptions.acknowledge(
110 request, subscription).then((_) => null);; 110 request, subscription).then((_) => null);
111 } 111 }
112 112
113 void _checkTopicName(name) { 113 void _checkTopicName(name) {
114 if (name.startsWith('projects/') && !name.contains('/topics/')) { 114 if (name.startsWith('projects/') && !name.contains('/topics/')) {
115 throw new ArgumentError( 115 throw new ArgumentError(
116 "Illegal topic name. Absolute topic names must have the form " 116 "Illegal topic name. Absolute topic names must have the form "
117 "'projects/[project-id]/topics/[topic-name]"); 117 "'projects/[project-id]/topics/[topic-name]");
118 } 118 }
119 if (name.endsWith('/topics/')) { 119 if (name.endsWith('/topics/')) {
120 throw new ArgumentError( 120 throw new ArgumentError(
(...skipping 349 matching lines...) Expand 10 before | Expand all | Expand 10 after
470 Future<Page<Subscription>> next({int pageSize}) { 470 Future<Page<Subscription>> next({int pageSize}) {
471 if (_nextPageToken == null) return new Future.value(null); 471 if (_nextPageToken == null) return new Future.value(null);
472 if (pageSize == null) pageSize = this._pageSize; 472 if (pageSize == null) pageSize = this._pageSize;
473 473
474 return _api._listSubscriptions( 474 return _api._listSubscriptions(
475 _topic, pageSize, _nextPageToken).then((response) { 475 _topic, pageSize, _nextPageToken).then((response) {
476 return new _SubscriptionPageImpl(_api, _topic, pageSize, response); 476 return new _SubscriptionPageImpl(_api, _topic, pageSize, response);
477 }); 477 });
478 } 478 }
479 } 479 }
OLDNEW
« no previous file with comments | « no previous file | pubspec.yaml » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698