dart project structure

Author: divshekhar

example/lib/main.dart

@@ -1,8 +1,4 @@
 import 'package:flutter/material.dart';
-import 'dart:async';
-
-import 'package:flutter/services.dart';
-import 'package:reflex/reflex.dart';
 
 void main() {
   runApp(const MyApp());
@@ -16,34 +12,9 @@ class MyApp extends StatefulWidget {
 }
 
 class _MyAppState extends State<MyApp> {
-  String _platformVersion = 'Unknown';
-
   @override
   void initState() {
     super.initState();
-    initPlatformState();
-  }
-
-  // Platform messages are asynchronous, so we initialize in an async method.
-  Future<void> initPlatformState() async {
-    String platformVersion;
-    // Platform messages may fail, so we use a try/catch PlatformException.
-    // We also handle the message potentially returning null.
-    try {
-      platformVersion =
-          await Reflex.platformVersion ?? 'Unknown platform version';
-    } on PlatformException {
-      platformVersion = 'Failed to get platform version.';
-    }
-
-    // If the widget was removed from the tree while the asynchronous platform
-    // message was in flight, we want to discard the reply rather than calling
-    // setState to update our non-existent appearance.
-    if (!mounted) return;
-
-    setState(() {
-      _platformVersion = platformVersion;
-    });
   }
 
   @override
@@ -53,8 +24,8 @@ class _MyAppState extends State<MyApp> {
         appBar: AppBar(
           title: const Text('Plugin example app'),
         ),
-        body: Center(
-          child: Text('Running on: $_platformVersion\n'),
+        body: const Center(
+          child: Text('App Running!!\n'),
         ),
       ),
     );

example/pubspec.lock

@@ -102,6 +102,13 @@ packages:
       url: "https://pub.dartlang.org"
     source: hosted
     version: "1.8.0"
+  plugin_platform_interface:
+    dependency: transitive
+    description:
+      name: plugin_platform_interface
+      url: "https://pub.dartlang.org"
+    source: hosted
+    version: "2.0.2"
   reflex:
     dependency: "direct main"
     description:

lib/reflex.dart

@@ -1,13 +1,12 @@
-
 import 'dart:async';
 
-import 'package:flutter/services.dart';
+import 'package:reflex/src/platform/reflex_platform.dart';
 
-class Reflex {
-  static const MethodChannel _channel = MethodChannel('reflex');
+export 'package:reflex/src/helper/helper.dart';
 
-  static Future<String?> get platformVersion async {
-    final String? version = await _channel.invokeMethod('getPlatformVersion');
-    return version;
+class Reflex {
+  /// [notificationStream] returns stream of notifications.
+  Stream<String> get notificationStream {
+    return ReflexPlatform.instance.notificationStream;
   }
 }

lib/src/handler/reflex_handler.dart

@@ -0,0 +1,38 @@
+/* 
+
+                  Copyright (c) 2022 DevsOnFlutter (Devs On Flutter)
+                            All rights reserved.
+
+The plugin is governed by the BSD-3-clause License. Please see the LICENSE file
+for more details.
+
+*/
+
+import 'dart:io';
+
+import 'package:flutter/services.dart';
+import 'package:reflex/src/helper/exception/reflex_exception.dart';
+import 'package:reflex/src/platform/reflex_platform.dart';
+
+class ReflexHandler extends ReflexPlatform {
+  // static const MethodChannel _methodChannel = MethodChannel('reflex');
+
+  static const EventChannel _eventChannel =
+      EventChannel('reflex_event_channel');
+
+  // MethodChannel get methodChannel => _methodChannel;
+  EventChannel get eventChannel => _eventChannel;
+
+  static Stream<String>? _notificationStream;
+
+  @override
+  Stream<String> get notificationStream {
+    if (Platform.isAndroid) {
+      _notificationStream ??=
+          _eventChannel.receiveBroadcastStream().map<String>((event) => event);
+      return _notificationStream!;
+    }
+    throw ReflexException(
+        'Reflex.notificationStream is only supported on Android.');
+  }
+}

lib/src/helper/exception/reflex_exception.dart

@@ -0,0 +1,20 @@
+/* 
+
+                Copyright (c) 2022 DevsOnFlutter (Devs On Flutter)
+                            All rights reserved.
+
+The plugin is governed by the BSD-3-clause License. Please see the LICENSE file
+for more details.
+
+*/
+
+class ReflexException implements Exception {
+  String message;
+
+  ReflexException(this.message);
+
+  @override
+  String toString() {
+    return "ReflexException: $message";
+  }
+}

lib/src/helper/helper.dart

@@ -0,0 +1,11 @@
+/* 
+
+                  Copyright (c) 2022 DevsOnFlutter (Devs On Flutter)
+                            All rights reserved.
+
+The plugin is governed by the BSD-3-clause License. Please see the LICENSE file
+for more details.
+
+*/
+
+export 'exception/reflex_exception.dart';

lib/src/platform/reflex_platform.dart

@@ -0,0 +1,33 @@
+/* 
+
+                  Copyright (c) 2022 DevsOnFlutter (Devs On Flutter)
+                            All rights reserved.
+
+The plugin is governed by the BSD-3-clause License. Please see the LICENSE file
+for more details.
+
+*/
+
+import 'package:plugin_platform_interface/plugin_platform_interface.dart';
+import 'package:reflex/src/handler/reflex_handler.dart';
+
+abstract class ReflexPlatform extends PlatformInterface {
+  ReflexPlatform() : super(token: _token);
+
+  static final Object _token = Object();
+
+  static ReflexPlatform _instance = ReflexHandler();
+
+  /// returns the instance of the [ReflexHandler].
+  static ReflexPlatform get instance => _instance;
+
+  static set instance(ReflexPlatform instance) {
+    PlatformInterface.verifyToken(instance, _token);
+    _instance = instance;
+  }
+
+  Stream<String> get notificationStream {
+    throw UnimplementedError(
+        'Getter notificationStream has not been implemented');
+  }
+}

pubspec.lock

@@ -95,6 +95,13 @@ packages:
       url: "https://pub.dartlang.org"
     source: hosted
     version: "1.8.0"
+  plugin_platform_interface:
+    dependency: "direct main"
+    description:
+      name: plugin_platform_interface
+      url: "https://pub.dartlang.org"
+    source: hosted
+    version: "2.0.2"
   sky_engine:
     dependency: transitive
     description: flutter

pubspec.yaml

@@ -10,6 +10,7 @@ environment:
 dependencies:
   flutter:
     sdk: flutter
+  plugin_platform_interface: ^2.0.2
 
 dev_dependencies:
   flutter_test:

test/reflex_test.dart

@@ -1,6 +1,6 @@
 import 'package:flutter/services.dart';
 import 'package:flutter_test/flutter_test.dart';
-import 'package:reflex/reflex.dart';
+// import 'package:reflex/reflex.dart';
 
 void main() {
   const MethodChannel channel = MethodChannel('reflex');
@@ -18,6 +18,6 @@ void main() {
   });
 
   test('getPlatformVersion', () async {
-    expect(await Reflex.platformVersion, '42');
+    // expect(await Reflex.platformVersion, '42');
   });
 }