lightstreamer_flutter_client 1.4.0-dev.2

A Flutter plugin for Lightstreamer.

example/lib/main.dart

import 'package:flutter/material.dart';
import 'dart:async';

import 'package:flutter/services.dart';
import 'package:lightstreamer_flutter_client/lightstreamer_flutter_client.dart';

// ignore: non_constant_identifier_names
String static_sub_id = "";

String _lastUpdate = " ---- ";

Color highlightcolorLast = Colors.blueGrey;

void main() {
  runApp(MyApp());
}

class MyApp extends StatefulWidget {
  @override
  _MyAppState createState() => _MyAppState();
}

class _MyAppState extends State<MyApp> {
  String _status = 'Unknown';
  final myController = TextEditingController();
  final mySubController = TextEditingController();
  final _client = LightstreamerClient();

  @override
  void initState() {
    super.initState();
    initPlatformState();
  }

  // Platform messages are asynchronous, so we initialize in an async method.
  Future<void> initPlatformState() async {
    LightstreamerClient.enableLog();

    String status;
    // Platform messages may fail, so we use a try/catch PlatformException.
    // We also handle the message potentially returning null.
    try {
      Map<String, String> params = {"user": "prova1", "password": "qwerty!"};

      _client.setClientListener(_clientStatus);
      status = await _client.connect(
              "https://push.lightstreamer.com/", "DEMO", params) ??
          'Unknown client session status';
    } on PlatformException {
      status = 'Failed to start Lighstreamer connection.';
    }

    // 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(() {
      _status = status;
    });
  }

  Future<void> _startRealTime() async {
    String currentStatus;

    try {
      Map<String, String> params = {
        "user": "prova1",
        "password": "qwerty!",
        "forcedTransport": "WS",
        "firstRetryMaxDelay": "1500",
        "retryDelay": "3850",
        "idleTimeout": "5000",
        "reconnectTimeout": "7500",
        "stalledTimeout": "pioajasol",
        "sessionRecoveryTimeout": "12500",
        "keepaliveInterval": "5000",
        "pollingInterval": "5700",
        "reverseHeartbeatInterval": "8890",
        "maxBandwidth": "10.1",
        "httpExtraHeaders": "{x-lightstreamer: prova1, x-test: abcdef}",
        "httpExtraHeadersOnSessionCreationOnly": "true",
        // "proxy": "{HTTP,localhost,19540,1,1}"
      };

      currentStatus = await _client.connect(
              "https://push.lightstreamer.com/", "DEMO", params) ??
          'Unknown client session status';
    } on PlatformException catch (e) {
      currentStatus =
          "Problems in starting a session with Lightstreamer: '${e.message}' .";
    }

    setState(() {
      _status = currentStatus;
    });
  }

  Future<void> _stopRealTime() async {
    String currentStatus;

    try {
      currentStatus = await _client.disconnect() ??
          'Unknown client session status';
    } on PlatformException catch (e) {
      currentStatus =
          "Problems in starting a session with Lightstreamer: '${e.message}' .";
    }

    setState(() {
      _status = currentStatus;
    });
  }

  Future<void> _getStatus() async {
    String result;

    try {
      result = await _client.getStatus() ?? ' -- ';
    } on PlatformException {
      result = "Unknown";
    }

    setState(() {
      _status = result;
    });
  }

  Future<void> _sendMessage() async {
    try {
      // await _client.sendMessage(myController.text);

      // await _client.sendMessageExt(
      //      "Hello World", "Sequence1", 5000, _clientmessages, true);
      await _client.sendMessageExt(
          myController.text, null, null, _clientmessages, true);
    } on PlatformException {
      // ...
    }
  }

  Future<void> _subscribe() async {
    String? subId = "";
    try {
      Map<String, String> params = {
        "dataAdapter": "QUOTE_ADAPTER",
        "requestedMaxFrequency": "7",
        "requestedSnapshot": "yes",
        // "commandSecondLevelDataAdapter": "QUOTE_ADAPTER",
        // "commandSecondLevelFields": "stock_name,last_price,time"
      };

      subId = await _client.subscribe(
          "MERGE",
          itemList: mySubController.text.split(","),
          fieldList: "last_price,time,stock_name".split(","),
          parameters: params);

      // subId = await _client.subscribe("COMMAND",
      //     "portfolio1".split(","), "key,command,qty".split(","), params);

      // Map<String, String> params2 = {
      //  "dataAdapter": "CHAT",
      //  "requestedMaxFrequency": "7",
      //  "requestedSnapshot": "yes"
      // };
      // subId = await _client.subscribe(
      //    "DISTINCT",
      //    mySubController.text.split(","),
      //    "message,timestamp".split(","),
      //    params2);

      static_sub_id = subId as String;

      _client.setSubscriptionListener(subId, _values);
    } on PlatformException {
      // ...
    }
  }

  void _values(String item, String fieldName, String fieldValue) {
    setState(() {
      _lastUpdate =
          item + "," + fieldName + "," + fieldValue + "\n" + _lastUpdate;
      highlightcolorLast = Colors.yellow;
    });
  }

  void _clientStatus(String msg) {
    setState(() {
      if (msg.startsWith("StatusChange")) {
        _status = msg.substring("StatusChange:".length);
      }
    });
  }

  void _clientmessages(String msg) {
    setState(() {
      _status = msg;
    });
  }

  Future<void> _unsubscribe() async {
    try {
      await _client.unsubscribe(static_sub_id);
    } on PlatformException {
      // ...
    }
  }

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: const Text('Lightstreamer Flutter Plugin Example'),
        ),
        body: Center(
          child: Column(
            // Column is also a layout widget. It takes a list of children and
            // arranges them vertically. By default, it sizes itself to fit its
            // children horizontally, and tries to be as tall as its parent.
            //
            // Invoke "debug painting" (press "p" in the console, choose the
            // "Toggle Debug Paint" action from the Flutter Inspector in Android
            // Studio, or the "Toggle Debug Paint" command in Visual Studio Code)
            // to see the wireframe for each widget.
            //
            // Column has various properties to control how it sizes itself and
            // how it positions its children. Here we use mainAxisAlignment to
            // center the children vertically; the main axis here is the vertical
            // axis because Columns are vertical (the cross axis would be
            // horizontal).
            mainAxisAlignment: MainAxisAlignment.center,
            children: <Widget>[
              ElevatedButton(
                child: const Text('Start Realtime from Lightstreamer'),
                onPressed: _startRealTime,
              ),
              ElevatedButton(
                child: const Text('Stop Realtime from Lightstreamer'),
                onPressed: _stopRealTime,
              ),
              ElevatedButton(
                child: const Text('Get Status'),
                onPressed: _getStatus,
              ),
              Text('Status of the connection: $_status\n'),
              TextField(
                decoration: InputDecoration(
                  border: OutlineInputBorder(),
                  hintText: 'Enter a message to send',
                ),
                controller: myController,
              ),
              ElevatedButton(
                child: const Text('Send Message'),
                onPressed: _sendMessage,
              ),
              TextField(
                decoration: InputDecoration(
                  border: OutlineInputBorder(),
                  hintText: 'Enter the list of items to subscribe',
                ),
                controller: mySubController,
              ),
              ElevatedButton(
                child: const Text('Subscribe'),
                onPressed: _subscribe,
              ),
              ElevatedButton(
                child: const Text('Unsubscribe'),
                onPressed: _unsubscribe,
              ),
              Text(_lastUpdate,
                  maxLines: 20,
                  style: TextStyle(backgroundColor: highlightcolorLast),
                  overflow: TextOverflow.fade,
                  textDirection: TextDirection.ltr,
                  textAlign: TextAlign.justify),
            ],
          ),
        ),
      ),
    );
  }
}