| OLD | NEW |
| (Empty) | |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
| 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. |
| 4 |
| 5 part of $LIBRARY; |
| 6 |
| 7 $(ANNOTATIONS)class $CLASSNAME$EXTENDS$NATIVESPEC { |
| 8 Stream<AudioProcessingEvent> _eventStream; |
| 9 |
| 10 /** |
| 11 * Get a Stream that fires events when AudioProcessingEvents occur. |
| 12 * This particular stream is special in that it only allows one listener to a |
| 13 * given stream. Converting the returned Stream [asBroadcast] will likely ruin |
| 14 * the soft-real-time properties which which these events are fired and can |
| 15 * be processed. |
| 16 */ |
| 17 Stream<AudioProcessingEvent> get onAudioProcess { |
| 18 if (_eventStream == null) { |
| 19 var controller = new StreamController(); |
| 20 var callback = (audioData) { |
| 21 if (controller.hasSubscribers) { |
| 22 // This stream is a strange combination of broadcast and single |
| 23 // subscriber streams. We only allow one listener, but if there is |
| 24 // no listener, we don't queue up events, we just drop them on the |
| 25 // floor. |
| 26 controller.add(audioData); |
| 27 } |
| 28 }; |
| 29 $if DART2JS |
| 30 JS('void', '#.onaudioprocess = #', this, |
| 31 convertDartClosureToJS(callback, 1)); |
| 32 $else |
| 33 // TODO(podivilov): Implement on Dartium. |
| 34 $endif |
| 35 |
| 36 _eventStream = controller.stream; |
| 37 } |
| 38 return _eventStream; |
| 39 } |
| 40 $!MEMBERS |
| 41 } |
| OLD | NEW |