Chromium Code Reviews| Index: pkg/observe/lib/src/observer_transform.dart |
| diff --git a/pkg/observe/lib/src/observer_transform.dart b/pkg/observe/lib/src/observer_transform.dart |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..75558631abef9618589b629dbb3e700015c11fab |
| --- /dev/null |
| +++ b/pkg/observe/lib/src/observer_transform.dart |
| @@ -0,0 +1,84 @@ |
| +// Copyright (c) 2013, 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 observe.src.observer_transform; |
| + |
| +import 'package:observe/observe.dart'; |
| + |
| +/// ObserverTransform is used to dynamically transform observed value(s). |
| +/// |
| +/// var obj = new ObservableBox(10); |
| +/// var observer = new PathObserver(obj, 'value'); |
| +/// var transform = new ObserverTransform(observer, |
| +/// (x) => x * 2, setValue: (x) => x ~/ 2); |
| +/// |
| +/// // Open returns the current value of 20. |
| +/// transform.open((newValue) => print('new: $newValue')); |
| +/// |
| +/// obj.value = 20; // prints 'new: 40' async |
| +/// new Future(() { |
| +/// transform.value = 4; // obj.value will be 2 |
| +/// }); |
| +/// |
| +/// ObserverTransform can also be used to reduce a set of observed values to a= |
|
Siggi Cherem (dart-lang)
2014/02/03 22:52:48
remove "="
Jennifer Messerly
2014/02/04 00:33:06
Done.
|
| +/// single value: |
| +/// |
| +/// var obj = new ObservableMap.from({'a': 1, 'b': 2, 'c': 3}); |
| +/// var observer = new CompoundObserver() |
| +/// ..addPath(obj, 'a') |
| +/// ..addPath(obj, 'b') |
| +/// ..addPath(obj, 'c'); |
| +/// |
| +/// var transform = new ObserverTransform(observer, |
| +/// (values) => values.fold(0, (x, y) => x + y)); |
| +/// |
| +/// // Open returns the current value of 6. |
| +/// transform.open((newValue) => print('new: $newValue')); |
| +/// |
| +/// obj['a'] = 2; |
| +/// obj['c'] = 10; // will print 'new 14' asynchronously |
| +/// |
| +class ObserverTransform extends Bindable { |
| + Bindable _bindable; |
| + Function _getValue, _setValue; |
| + Function _notifyCallback; |
| + var _value; |
| + |
| + ObserverTransform(Bindable bindable, computeValue(value), {setValue(value)}) |
| + : _bindable = bindable, _getValue = computeValue, _setValue = setValue; |
| + |
| + open(callback(value)) { |
| + _notifyCallback = callback; |
| + _value = _getValue(_bindable.open(_observedCallback)); |
| + return _value; |
| + } |
| + |
| + _observedCallback(value) { |
| + value = _getValue(value); |
|
Siggi Cherem (dart-lang)
2014/02/03 22:52:48
Consider introducing a new variable here:
var tra
Jennifer Messerly
2014/02/04 00:33:06
sure
|
| + if (value == _value) return null; |
| + _value = value; |
| + return _notifyCallback(value); |
| + } |
| + |
| + void close() { |
| + if (_bindable != null) _bindable.close(); |
| + _bindable = null; |
| + _getValue = null; |
| + _setValue = null; |
| + _notifyCallback = null; |
| + _value = null; |
| + } |
| + |
| + get value { |
|
Siggi Cherem (dart-lang)
2014/02/03 22:52:48
not sure if I like this suggestion, but here it go
Jennifer Messerly
2014/02/04 00:33:06
Done.
|
| + _value = _getValue(_bindable.value); |
| + return _value; |
| + } |
| + |
| + set value(newValue) { |
| + if (_setValue != null) { |
| + newValue = _setValue(newValue); |
| + } |
|
Siggi Cherem (dart-lang)
2014/02/03 22:52:48
mmm, I was expecting that if _setValue == null, th
Jennifer Messerly
2014/02/04 00:33:06
we still want to pass on the value, just we don't
|
| + _bindable.value = newValue; |
| + } |
| +} |