send method

Future<void> send(String message, { String persistKey = 'defaultPersistKey', })

Sends a message to the WebSocket server.

Optionally persists the message if persistStream is true.

Implementation

Future<void> send(String message, {String persistKey = 'defaultPersistKey'}) async {
  if (_socketConfig.persistStream) {
    var old = _prefs?.getStringList(persistKey) ?? [];
    old.add(message);
    var success = await _prefs?.setStringList(persistKey, old);
    if (success == false) {
      log('Persistence Failed', name: 'Persisting message');
    }
  }
  _channel?.sink.add(message);
}