cargdev/angular
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(ddc): type fixes necessary to bring DDC severe count to 0

Browse Source
This commit is contained in:
Yegor Jbanov
2016-01-21 18:13:58 -08:00
committed by Yegor
parent 9c96b8affc
commit 4282297c24
13 changed files with 82 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
modules/angular2/src/facade/async.dart
View File

@ -73,16 +73,16 @@ class ObservableWrapper {
}
class EventEmitter<T> extends Stream<T> {
StreamController<dynamic> _controller;
StreamController<T> _controller;
/// Creates an instance of [EventEmitter], which depending on [isAsync],
/// delivers events synchronously or asynchronously.
EventEmitter([bool isAsync = true]) {
_controller = new StreamController.broadcast(sync: !isAsync);
_controller = new StreamController<T>.broadcast(sync: !isAsync);
}
StreamSubscription listen(void onData(dynamic line),
{void onError(Error error), void onDone(), bool cancelOnError}) {
StreamSubscription<T> listen(void onData(T event),
{Function onError, void onDone(), bool cancelOnError}) {
return _controller.stream.listen(onData,
onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}
@ -106,14 +106,14 @@ class EventEmitter<T> extends Stream<T> {
//todo(robwormald): maybe fix in ts2dart?
class Subject<T> extends Stream<T> {
StreamController<dynamic> _controller;
StreamController<T> _controller;
Subject([bool isAsync = true]) {
_controller = new StreamController.broadcast(sync: !isAsync);
_controller = new StreamController<T>.broadcast(sync: !isAsync);
}
StreamSubscription listen(void onData(dynamic line),
{void onError(Error error), void onDone(), bool cancelOnError}) {
StreamSubscription<T> listen(void onData(T data),
{Function onError, void onDone(), bool cancelOnError}) {
return _controller.stream.listen(onData,
onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}