Merge branch 'siyaoH/1.17/stream' of github.com:Unity-Technologies/com.unity.uiwidgets into stream/ide_fixes

Samples/UIWidgetsSamples_2019_4/Assets/Script/StreamTest.cs

 using System;
+using System.Collections;
-using System.Timers;
-using Unity.UIWidgets.animation;
+using uiwidgets;
-using Unity.UIWidgets.painting;
-using Unity.UIWidgets.ui;
-using FontStyle = Unity.UIWidgets.ui.FontStyle;
-using Image = Unity.UIWidgets.widgets.Image;
-using TextStyle = Unity.UIWidgets.painting.TextStyle;
-using UnityEngine;
+using Unity.UIWidgets.painting;
+using Unity.UIWidgets.ui;
+using UnityEngine.Networking;
+using Image = Unity.UIWidgets.widgets.Image;
 using Timer = Unity.UIWidgets.async.Timer;
 
 namespace UIWidgetsSample
 
         class ExampleState : State<ExampleApp>
         {
-            int counter;
-            
-            
-            
+
+            IEnumerator _loadCoroutine(string key, Completer completer, Isolate isolate) {
+                var url = new Uri(key);
+                using (var www = UnityWebRequest.Get(url)) {
+                    yield return www.SendWebRequest();
+                    using (Isolate.getScope(isolate)) {
+                        if (www.isNetworkError || www.isHttpError) {
+                            completer.completeError(new Exception($"Failed to load from url \"{url}\": {www.error}"));
+                            yield break;
+                        }
+
+                        var data = www.downloadHandler.data;
+                        completer.complete(data);
+                    }
+                }
+            }
-                myStream.listen(d => { Debug.Log($"count: {d}"); });
-                
+                Future<byte[]> f = null;
+                var completer = Completer.create();
+                var isolate = Isolate.current;
+                var panel = UIWidgetsPanelWrapper.current.window;
+                if (panel.isActive()) {
+                    panel.startCoroutine(_loadCoroutine("https://buljan.rcsdk8.org/sites/main/files/main-images/camera_lense_0.jpeg", completer, isolate));
+                     f = completer.future.to<byte[]>().then_<byte[]>(data => {
+                        if (data != null && data.Length > 0) {
+                            return data;
+                        }
+
+                        throw new Exception("not loaded");
+                    });
+                }
+                var futureBuilder = new FutureBuilder<byte[]>(
+                    future: f,
+                    builder: (ctx, snapshot) =>
+                    {
+                        int width = 200;
+                        int height = 200;
+                        Color color = Colors.blue;
+                        if (snapshot.connectionState == ConnectionState.done)
+                        {
+                            return new Container(alignment: Alignment.center, width: width, height:height, color: color, child: Image.memory(snapshot.data) );
+                        } else if (snapshot.connectionState == ConnectionState.waiting)
+                        {
+                            return new Container(alignment: Alignment.center, width: width, height:height, color: color, child: new Text("waiting") );
+                        }
+                        else
+                        {
+                            return new Container(alignment: Alignment.center, width: width, height:height, color: color, child: new Text("else") );
+                        }
+                    }
+                );
+                var streamBuilder = new StreamBuilder<int>(
+                    stream: myStream,
+                    initialData: 1,
+                    builder: (ctx, snapshot) =>
+                    {
+                        var data = snapshot.data;
+                        return new Container(child: new Text($"stream data: {data}"));
+                    }
+                );
+
-                    color: Color.fromARGB(255, 255, 0, 0),
+                    color: Colors.blueGrey,
-                            new Text("Counter: " + counter,
-                                style: new TextStyle(fontSize: 18, fontWeight: FontWeight.w100)),
-
-                            new GestureDetector(
-                                onTap: () =>
-                                {
-                                    setState(() =>
-                                    {
-                                        counter++;
-                                    });
-                                },
-                                child: new Container(
-                                    padding: EdgeInsets.symmetric(20, 20),
-                                    color: counter % 2 == 0 ? Color.fromARGB(255, 0, 255, 0) : Color.fromARGB(255, 0, 0, 255),
-                                    child: new Text("Click Me",
-                                        style: new TextStyle(fontFamily: "racher", fontWeight: FontWeight.w100))
-                                )
-                            )
+                            streamBuilder,
+                            futureBuilder
                         }
                     )
                 );

com.unity.uiwidgets/Runtime/async/stream.cs

         }
 
         // const Stream._internal();
-        
+
         public static Stream<T> empty() => new _EmptyStream<T>();
 
         // @Since("2.5")
                         return;
                     }
 
-                    if (newValue.f is Future<E> newFuture) { // siyao: this if different from dart
+                    if (newValue.f is Future<E> newFuture) {
+                        // siyao: this if different from dart
                         subscription.pause();
                         newFuture
                             .then(d => add((E) d), onError: (e) => {
     }
 
 // /** [Stream] wrapper that only exposes the [Stream] interface. */
-// class StreamView<T> extends Stream<T> {
-//   final Stream<T> _stream;
+    public class StreamView<T> : Stream<T> {
+        readonly Stream<T> _stream;
-//   const StreamView(Stream<T> stream)
-//       : _stream = stream,
-//         super._internal();
+        public StreamView(Stream<T> stream) : base() {
+            _stream = stream;
+        }
-//   bool get isBroadcast => _stream.isBroadcast;
+        public override bool isBroadcast {
+            get { return _stream.isBroadcast; }
+        }
-//   Stream<T> asBroadcastStream(
-//           {void onListen(StreamSubscription<T> subscription),
-//           void onCancel(StreamSubscription<T> subscription)}) =>
-//       _stream.asBroadcastStream(onListen: onListen, onCancel: onCancel);
+        public override Stream<T> asBroadcastStream(Action<StreamSubscription<T>> onListen = null,
+            Action<StreamSubscription<T>> onCancel = null)
+            =>
+                _stream.asBroadcastStream(onListen: onListen, onCancel: onCancel);
-//   StreamSubscription<T> listen(void onData(T value),
-//       {Function onError, void onDone(), bool cancelOnError}) {
-//     return _stream.listen(onData,
-//         onError: onError, onDone: onDone, cancelOnError: cancelOnError);
-//   }
-// }
+        public override StreamSubscription<T> listen(Action<T> onData, Action<object, string> onError = null,
+            Action onDone = null, bool cancelOnError = false) {
+            return _stream.listen(onData,
+                onError: onError, onDone: onDone, cancelOnError: cancelOnError);
+        }
+    }
 
     public interface StreamConsumer<S> {
         Future addStream(Stream<S> stream);

com.unity.uiwidgets/Runtime/widgets/async.cs

     }
 
 // TODO(ianh): remove unreachable code above once https://github.com/dart-lang/linter/issues/1141 is fixed
-    class FutureBuilder<T> : StatefulWidget {
+    public class FutureBuilder<T> : StatefulWidget {
         public FutureBuilder(
             _async.AsyncWidgetBuilder<T> builder,
             Key key = null,