Chromium Code Reviews| Index: microlytics/lib/channels.dart |
| diff --git a/microlytics/lib/channels.dart b/microlytics/lib/channels.dart |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..42cd00d098363b543973a078e722401fc687d6c9 |
| --- /dev/null |
| +++ b/microlytics/lib/channels.dart |
| @@ -0,0 +1,55 @@ |
| +// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
| +// for details. All rights reserved. Use of this source code is governed by a |
| +// BSD-style license that can be found in the LICENSE file. |
| + |
| +library microlytics.channels; |
| + |
| +import 'dart:async'; |
| + |
| +final String ANALYTICS_URL = "https://www.google-analytics.com/collect"; |
|
ahe
2014/09/03 08:51:31
I'm not sure this is related to channels.
lukechurch
2014/09/04 12:58:41
True. I thought that having a separate class to de
|
| + |
| +abstract class Channel { |
| + void sendData(String data); |
| + void shutdown() {} |
| +} |
| + |
| +/// [Channel] that implements a leaky bucket |
| +/// algorithm to provide rate limiting. |
| +/// See (http://en.wikipedia.org/wiki/Leaky_bucket) |
|
ahe
2014/09/03 08:51:31
Add period, and use [] instead of ().
lukechurch
2014/09/04 12:58:41
Done.
|
| +class RateLimitingBufferedChannel extends Channel { |
| + final List<String> _buffer = <String>[]; |
| + final Channel _innerChannel; |
| + final int bufferSizeLimit; |
| + Timer _timer; |
| + |
| + RateLimitingBufferedChannel( |
| + this._innerChannel, |
| + { this.bufferSizeLimit: 10, |
|
ahe
2014/09/03 08:51:31
Remove space after {.
lukechurch
2014/09/04 12:58:41
Done.
|
| + double packetsPerSecond: 1.0}) { |
| + if (!(packetsPerSecond > 0)) { |
| + throw new ArgumentError("packetsPerSecond must be larger than zero"); |
| + } |
| + |
| + int transmitDelay = (1000 / packetsPerSecond).floor(); |
| + _timer = new Timer(new Duration(milliseconds: transmitDelay), () { |
| + _onTimerTick(); |
| + }); |
| + } |
| + |
| + void _onTimerTick() { |
| + if (_buffer.length > 0) { |
| + String item = _buffer.removeLast(); |
| + _innerChannel.sendData(item); |
| + } |
| + } |
| + |
| + void sendData(String data) { |
| + if (_buffer.length >= bufferSizeLimit) return; |
| + _buffer.add(data); |
| + } |
| + |
| + void shutdown() { |
| + _timer.cancel(); |
| + _innerChannel.shutdown(); |
| + } |
| +} |