整理,修改readme,例子

Author: unreal0

.vscode/launch.json

@@ -9,11 +9,6 @@
       "type": "dart",
       "request": "launch",
       "program": "example/lib/main.dart"
-    },
-    {
-      "name": "Flutter",
-      "request": "launch",
-      "type": "dart"
     }
   ]
 }

README.md

@@ -1,10 +1,10 @@
 # Parse Server Dart
+
 A rewrite of a library hosted on GitHub. This is not my own content but based on a library already created and looks to be abandoned.
 
 https://github.com/lotux/parse_server_dart
 
-## Join in!
-Want to get involved? Join our Slack channel and help out! FlutterParseSDK.Slack.com
+## example 目录有完整测试
 
 ## Getting Started
 

example/README.md

@@ -1,8 +1,9 @@
-# flutter_plugin_example
+# flutter_parse_client_example
 
-Demonstrates how to use the flutter_plugin plugin.
+Demonstrates how to use the flutter parse client.
 
-## Getting Started
+## html ok
 
-For help getting started with Flutter, view our online
-[documentation](https://flutter.io/).
+## websoket ok
+
+## bloc

example/android/app/src/main/AndroidManifest.xml

@@ -14,7 +14,7 @@
          FlutterApplication and put your custom class here. -->
     <application
         android:name="io.flutter.app.FlutterApplication"
-        android:label="flutter_plugin_example"
+        android:label="parse_example"
         android:icon="@mipmap/ic_launcher">
         <activity
             android:name=".MainActivity"

example/lib/ApplicationBloc.dart

@@ -0,0 +1,38 @@
+import 'dart:async';
+
+import 'package:Parse_example/blocProvider.dart';
+import 'package:parse_server_sdk/network/parse_livequery.dart';
+
+class ApplicationBloc implements BlocBase {
+  ///
+  /// Synchronous Stream to handle the provision of the movie genres
+  ///
+  StreamController<List> _syncController = StreamController<List>.broadcast();
+  Stream<List> get outParseStream => _syncController.stream;
+
+  ///
+  StreamController<List> _cmdController = StreamController<List>.broadcast();
+  StreamSink get getMovieGenres => _cmdController.sink;
+
+  List _genresList;
+
+  ApplicationBloc(LiveQuery liveQuery) {
+    // _genresList = liveQuery.channel as List;
+    // Read all genres from Internet
+    // api.movieGenres().then((list) {
+    //   _genresList = list;
+    // });
+    _syncController.stream.listen((_) {
+      _syncController.sink.addStream(liveQuery.channel.stream);
+    });
+    // _cmdController.stream.listen((_) {
+    //   _syncController.sink
+    //       .add(UnmodifiableListView<MovieGenre>(_genresList.genres));
+    // });
+  }
+
+  void dispose() {
+    _syncController.close();
+    _cmdController.close();
+  }
+}

example/lib/IncrementBloc.dart

@@ -0,0 +1,32 @@
+import 'dart:async';
+
+import 'package:Parse_example/blocProvider.dart';
+
+class IncrementBloc implements BlocBase {
+  int _counter;
+
+  // 处理counter的stream
+  StreamController<int> _counterController = StreamController<int>();
+  StreamSink<int> get _inAdd => _counterController.sink;
+  Stream<int> get outCounter => _counterController.stream;
+
+  // 处理业务逻辑的stream
+  StreamController _actionController = StreamController();
+  StreamSink get incrementCounter => _actionController.sink;
+
+  // 构造器
+  IncrementBloc() {
+    _counter = 0;
+    _actionController.stream.listen(_handleLogic);
+  }
+
+  void dispose() {
+    _actionController.close();
+    _counterController.close();
+  }
+
+  void _handleLogic(data) {
+    _counter = _counter + 1;
+    _inAdd.add(_counter);
+  }
+}

example/lib/application_constants.dart

@@ -3,4 +3,5 @@ abstract class ApplicationConstants {
   static const String PARSE_APPLICATION_ID = "myAppId";
   static const String PARSE_MASTER_KEY = "123456";
   static const String PARSE_SERVER_URL = "http://118.24.162.252:2018/parse";
+  static const String PARSE_LIVE_SERVER_URL = "ws://118.24.162.252:2018/parse";
 }

example/lib/blocProvider.dart

@@ -0,0 +1,40 @@
+import 'package:flutter/material.dart';
+
+abstract class BlocBase {
+  void dispose();
+}
+
+class BlocProvider<T extends BlocBase> extends StatefulWidget {
+  BlocProvider({
+    Key key,
+    @required this.child,
+    @required this.bloc,
+  }) : super(key: key);
+
+  final T bloc;
+  final Widget child;
+
+  @override
+  _BlocProviderState<T> createState() => _BlocProviderState<T>();
+
+  static T of<T extends BlocBase>(BuildContext context) {
+    final type = _typeOf<BlocProvider<T>>();
+    BlocProvider<T> provider = context.ancestorWidgetOfExactType(type);
+    return provider.bloc;
+  }
+
+  static Type _typeOf<T>() => T;
+}
+
+class _BlocProviderState<T> extends State<BlocProvider<BlocBase>> {
+  @override
+  void dispose() {
+    widget.bloc.dispose();
+    super.dispose();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return widget.child;
+  }
+}

example/lib/count_bloc.dart

@@ -0,0 +1,19 @@
+import 'dart:async';
+import 'package:Parse_example/blocProvider.dart';
+import 'package:rxdart/rxdart.dart';
+
+class CountBLoC implements BlocBase {
+  int _count = 0;
+  var _countController = StreamController<int>.broadcast();
+  var _subject = BehaviorSubject<int>();
+  Stream<int> get stream => _subject.stream;
+  int get value => _count;
+
+  increment() {
+    _countController.sink.add(++_count);
+  }
+
+  dispose() {
+    _countController.close();
+  }
+}

example/lib/gametest/GameCommunication.dart

@@ -0,0 +1,116 @@
+import 'dart:convert';
+
+import 'package:flutter/foundation.dart';
+import 'WebSocketsNotifications.dart';
+
+///
+/// Again, application-level global variable
+///
+GameCommunication game = new GameCommunication();
+
+class GameCommunication {
+  static final GameCommunication _game = new GameCommunication._internal();
+
+  ///
+  /// At first initialization, the player has not yet provided any name
+  ///
+  String _playerName = "";
+
+  ///
+  /// Before the "join" action, the player has no unique ID
+  ///
+  String _playerID = "";
+
+  factory GameCommunication() {
+    return _game;
+  }
+
+  GameCommunication._internal() {
+    ///
+    /// Let's initialize the WebSockets communication
+    ///
+    sockets.initCommunication();
+
+    ///
+    /// and ask to be notified as soon as a message comes in
+    ///
+    sockets.addListener(_onMessageReceived);
+  }
+
+  ///
+  /// Getter to return the player's name
+  ///
+  String get playerName => _playerName;
+
+  /// ----------------------------------------------------------
+  /// Common handler for all received messages, from the server
+  /// ----------------------------------------------------------
+  _onMessageReceived(serverMessage) {
+    ///
+    /// As messages are sent as a String
+    /// let's deserialize it to get the corresponding
+    /// JSON object
+    ///
+    Map message = json.decode(serverMessage);
+
+    switch (message["action"]) {
+
+      ///
+      /// When the communication is established, the server
+      /// returns the unique identifier of the player.
+      /// Let's record it
+      ///
+      case 'connect':
+        _playerID = message["data"];
+        break;
+
+      ///
+      /// For any other incoming message, we need to
+      /// dispatch it to all the listeners
+      ///
+      default:
+        _listeners.forEach((Function callback) {
+          callback(message);
+        });
+        break;
+    }
+  }
+
+  /// ----------------------------------------------------------
+  /// Common method to send requests to the server
+  /// ----------------------------------------------------------
+  send(String action, String data) {
+    ///
+    /// When a player joins, we need to record the name
+    /// he provides
+    ///
+    if (action == 'join') {
+      _playerName = data;
+    }
+
+    ///
+    /// Send the action to the server
+    /// To send the message, we need to serialize the JSON
+    ///
+    sockets.send(json.encode({"action": action, "data": data}));
+  }
+
+  /// ==========================================================
+  ///
+  /// Listeners to allow the different pages to be notified
+  /// when messages come in
+  ///
+  ObserverList<Function> _listeners = new ObserverList<Function>();
+
+  /// ---------------------------------------------------------
+  /// Adds a callback to be invoked in case of incoming
+  /// notification
+  /// ---------------------------------------------------------
+  addListener(Function callback) {
+    _listeners.add(callback);
+  }
+
+  removeListener(Function callback) {
+    _listeners.remove(callback);
+  }
+}