DBusRemoteObjectSignalStreamProxy constructor

DBusRemoteObjectSignalStreamProxy({
  1. required DBusRemoteObjectProxy object,
  2. required String name,
  3. required String interface,
  4. DBusSignature? signature,
})

Implementation

DBusRemoteObjectSignalStreamProxy({
  required this.object,
  required this.name,
  required this.interface,
  super.signature,
})  : _useWebSocket = kIsWeb,
      super(object: object, interface: interface, name: name) {
  if (_useWebSocket) {
    _connectToWebSocket();

    _channel!.stream.listen(
      (message) {
        _messageController.add({'message': message});
      },
      onError: (error) {
        _messageController.addError(error);
      },
      onDone: () {
        _messageController.close();
      },
    );
  }
}