| Index: pkg/microlytics/lib/channels.dart
|
| diff --git a/pkg/microlytics/lib/channels.dart b/pkg/microlytics/lib/channels.dart
|
| index 88dee4988d822b7bd390b35532fcaf080f856cf6..18f233c19f9585808dc0a2e0f70d041928116e0d 100644
|
| --- a/pkg/microlytics/lib/channels.dart
|
| +++ b/pkg/microlytics/lib/channels.dart
|
| @@ -22,10 +22,8 @@ class RateLimitingBufferedChannel extends Channel {
|
| final int _bufferSizeLimit;
|
| Timer _timer;
|
|
|
| - RateLimitingBufferedChannel(
|
| - this._innerChannel,
|
| - {int bufferSizeLimit: 10,
|
| - double packetsPerSecond: 1.0})
|
| + RateLimitingBufferedChannel(this._innerChannel,
|
| + {int bufferSizeLimit: 10, double packetsPerSecond: 1.0})
|
| : this._bufferSizeLimit = bufferSizeLimit {
|
| if (!(packetsPerSecond > 0)) {
|
| throw new ArgumentError("packetsPerSecond must be larger than zero.");
|
| @@ -52,4 +50,4 @@ class RateLimitingBufferedChannel extends Channel {
|
| _timer.cancel();
|
| _innerChannel.shutdown();
|
| }
|
| -}
|
| +}
|
|
|