commit

Author: zhujian1989

.idea/workspace.xml

@@ -111,21 +111,10 @@ main() {
 //  ])
 //      .listen(print);
 
-//
-//      BaseModel<int> model = new BaseModel<int>(error: false, results: 1);
-//
-//
-//      StreamController<BaseModel<int>> controller  = new StreamController<BaseModel<int>>();
-//
-//      controller.add(model);
-//
-//      controller.stream.transform(new DoStreamTransformer(onData: print,onDone: (){
-//
-//      }));
-//
-//
-//
 
+  new Observable.fromIterable([1, 2]).withLatestFrom(
+             new Observable.fromIterable([2, 3]), (a, b) => a + b)
+             .listen(print);
 
 }
 

lib/widget/demo_advance/test.dart

@@ -27,10 +27,8 @@ class SearchBloc {
             .error && null != value.results && value.results.length > 0) ? value
             .results : null).asBroadcastStream();
 
-
-    _log = Observable(results)
-        .withLatestFrom(_query.stream, (_, query) => '当前搜索的关键字： $query')
-        .asBroadcastStream();
+    _log = new Observable(_query.stream).map((value) => '当前搜索关键字：$value');
+    
   }
 
   void dispose() {