dependencies:
  flutter:
    sdk: flutter

  cupertino_icons: ^1.0.2
  flutter_riverpod: ^1.0.4

dev_dependencies:
  flutter_test:
    sdk: flutter

  flutter_lints: ^2.0.0

package com.example.message_channel_demo

import android.os.Handler
import android.os.Looper
import androidx.annotation.NonNull
import androidx.annotation.Nullable
import io.flutter.Log
import io.flutter.embedding.android.FlutterActivity
import io.flutter.embedding.engine.FlutterEngine
import io.flutter.plugin.common.BasicMessageChannel
import io.flutter.plugin.common.StringCodec
import io.flutter.plugin.common.JSONMessageCodec
import io.flutter.plugin.common.StandardMessageCodec
import io.flutter.plugins.GeneratedPluginRegistrant

class MainActivity : FlutterActivity() {
    private val channelName = "samples.flutter.dev/counter"

    override fun configureFlutterEngine(@NonNull flutterEngine: FlutterEngine) {
        super.configureFlutterEngine(flutterEngine)
        val channel : BasicMessageChannel<Any?> = BasicMessageChannel<Any?>(flutterEngine.dartExecutor.binaryMessenger, channelName, StandardMessageCodec())
        val handler : MyMessageHandler = MyMessageHandler(channel)
        channel.setMessageHandler(handler)
    }
}

class MyMessageHandler constructor (val channel : BasicMessageChannel<Any?>) : BasicMessageChannel.MessageHandler<Any?> {
    private val handler = Handler(Looper.getMainLooper())
    private var counter: Int = 0
    private val runnable: Runnable = object : Runnable {
        override fun run() {
            sendMsgToFlutter()
        }
    }

    init {
        handler.post(runnable)
    }

    fun sendMsgToFlutter() {
        channel.send(getCounter()) { reply ->
            Log.d("Android", "$reply")
        }
        handler.postDelayed(runnable, 4000)
    }

    private fun getCounter() : Map<String, Any> {
        return mapOf("name" to "Native", "counter" to counter++)
    }

    override fun onMessage(message: Any?, reply: BasicMessageChannel.Reply<Any?>) {
        val name = (message as Map<String, Any>)["name"]
        val cnt = (message as Map<String, Any>)["counter"]
        Log.d("Android", "<Msg From Flutter> = Name:$name, Counter:$cnt")
        reply.reply("Hey, $name! Your counter is : $cnt")
    }
}

// ignore_for_file: avoid_print

import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:message_channel_demo/models/counter_data.dart';
import 'package:message_channel_demo/notifiers/counter_notifier.dart';
import 'views/home.dart';

final counterProvider =
    StateNotifierProvider<CounterNotifier, CounterData>((ref) {
  return CounterNotifier();
});

void main() {
  runApp(const ProviderScope(child: MyApp()));
}

class MyApp extends StatelessWidget {
  const MyApp({Key? key}) : super(key: key);

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter MessageChannel',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: MyHomePage(title: 'Flutter MessageChannel'),
    );
  }
}

// ignore_for_file: avoid_print

import 'dart:async';
import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:message_channel_demo/main.dart';
import '../repository/counter_repository.dart';

class MyHomePage extends ConsumerWidget {
  MyHomePage({Key? key, required String title}) : super(key: key);
  bool _isLoading = false;

  @override
  Widget build(BuildContext context, WidgetRef ref) {
    final data = ref.watch(counterProvider);
    final counterNotifier = ref.read(counterProvider.notifier);
    if (_isLoading == false) {
      _init(counterNotifier);
      _isLoading = true;
    }

    return Scaffold(
      appBar: AppBar(
        title: const Text('Flutter MessageChannel'),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            Text('Counter of ${data.nativeName}: ${data.nativeCounter}',
                style: Theme.of(context).textTheme.headline4),
            const SizedBox(height: 20),
            Text('Counter of ${data.flutterName}: ${data.flutterCounter}',
                style: Theme.of(context).textTheme.headline4),
          ],
        ),
      ),
    );
  }

  void _init(notifier) {
    final CounterRepository counterRepository = CounterRepository();
    counterRepository.setMessageHandler(notifier);

    int flutterCounter = 0;
    counterRepository.sendMsgToNative(notifier, flutterCounter++);
    Timer.periodic(const Duration(seconds: 9), (_) {
      counterRepository.sendMsgToNative(notifier, flutterCounter++);
    });
  }
}

import 'package:flutter/material.dart';

@immutable
class CounterData {
  final String nativeName;
  final int? nativeCounter;
  final String flutterName;
  final int? flutterCounter;
  const CounterData(
      {required this.nativeName,
      required this.nativeCounter,
      required this.flutterName,
      required this.flutterCounter});
}

// ignore_for_file: avoid_print

import 'package:flutter/services.dart';

class CounterRepository {
  static const _channel = BasicMessageChannel<dynamic>(
      'samples.flutter.dev/counter', StandardMessageCodec());

  void setMessageHandler(notifier) {
    _channel.setMessageHandler((message) async {
      var name = message['name'] as String;
      var cnt = message['counter'] as int;
      notifier.setNativeData(name, cnt);
      print('[Msg From Native] = Name:$name, Counter:$cnt');
      return 'Hey, $name! Your counter is : $cnt';
    });
  }

  void sendMsgToNative(notifier, flutterCounter) async {
    final reply = await _channel.send(<String, dynamic>{
      'name': 'Flutter',
      'counter': '$flutterCounter',
    });
    notifier.setFlutterData('Flutter', flutterCounter);
    print(reply);
  }
}

import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:message_channel_demo/models/counter_data.dart';

class CounterNotifier extends StateNotifier<CounterData> {
  CounterNotifier()
      : super(const CounterData(
            nativeName: '',
            nativeCounter: 0,
            flutterName: '',
            flutterCounter: 0));

  void setNativeData(String nativeName, int? nativeCounter) {
    state = CounterData(
        nativeName: nativeName,
        nativeCounter: nativeCounter,
        flutterName: state.flutterName,
        flutterCounter: state.flutterCounter);
  }

  void setFlutterData(String flutterName, int? flutterCounter) {
    state = CounterData(
        nativeName: state.nativeName,
        nativeCounter: state.nativeCounter,
        flutterName: flutterName,
        flutterCounter: flutterCounter);
  }
}