@@ -222,0 +184,4 @@
+        val eventBus: MethodChannel = mc
+
+        override fun onReceive(context: Context, intent: Intent) {
+//            StringBuilder().apply {

@@ -85,0 +95,4 @@
+    // WorkManager
+
+    // (Java only)
+    //implementation("androidx.work:work-runtime:$work_version")

@@ -0,0 +19,4 @@
+
+class FlwtchWorker(context: Context, parameters: WorkerParameters) :
+        CoroutineWorker(context, parameters) {
+    private val CWTCH_EVENTBUS = "test.flutter.dev/eventBus"

@@ -0,0 +62,4 @@
+                // infinite coroutine :)
+                while(true) {
+                    val evt = MainActivity.AppbusEvent(Cwtch.getAppBusEvent())
+                    //Log.i("FlwtchWorker.kt", "got appbusEvent: " + evt)

@@ -0,0 +114,4 @@
+//                            .putString("EventID", evt.EventID)
+//                            .build()
+                    //setProgress(data)//progress can only hold a single undelivered value so it's possible for observers to miss rapidfire updates
+                    //Thread.sleep(200)//this is a kludge to make it mostly-work until a proper channel is implemented

@@ -0,0 +149,4 @@
+                return Result.success(Data.Builder().putLong("result", Cwtch.numMessages(profile, handle)).build())
+            }
+            "GetMessage" -> {
+                //Log.i("MainActivivity.kt", (a.get("index")));

@@ -30,3 +30,1 @@
-task clean(type: Delete) {
-    delete rootProject.buildDir
-}
+//task clean(type: Delete) {