web3mq 0.1.2

web3mq: ^0.1.2 copied to clipboard

example/web3mq_example.dart

import 'package:web3mq/web3mq.dart';

Future<void> main() async {
  final client = Web3MQClient('api-key');

  final user = User("userId", DID("type", "value"), "sessionKey");
  await client.connectUser(user);

  client.notificationStream.listen((event) {
    // handle with the notifications.
  });

  // send message
  client.sendText('text', 'topic');

  client.newMessageStream.listen((event) {
    // handle the new message
  });
}