diff --git a/rust/bindings/dart_vdd/lib/src/generated/api.dart b/rust/bindings/dart_vdd/lib/src/generated/api.dart
index d1981026..f99acbae 100644
--- a/rust/bindings/dart_vdd/lib/src/generated/api.dart
+++ b/rust/bindings/dart_vdd/lib/src/generated/api.dart
@@ -93,12 +93,31 @@ class VirtualDisplayDriver extends RustOpaque {
   /// current state of the driver.
   ///
   /// After calling, will instantly emit the current state of the driver.
-  Future<Stream<List<Monitor>>> get stream =>
+  Stream<List<Monitor>> get stream =>
       RustLib.instance.api.virtualDisplayDriverStream(
         that: this,
       );
 }
 
+@freezed
+sealed class IpcError with _$IpcError implements FrbException {
+  const IpcError._();
+
+  const factory IpcError.serDe(
+    String field0,
+  ) = IpcError_SerDe;
+  const factory IpcError.io(
+    String field0,
+  ) = IpcError_Io;
+  const factory IpcError.win(
+    String field0,
+  ) = IpcError_Win;
+  const factory IpcError.client(
+    String field0,
+  ) = IpcError_Client;
+  const factory IpcError.requestState() = IpcError_RequestState;
+}
+
 @freezed
 class Mode with _$Mode {
   const factory Mode({
diff --git a/rust/bindings/dart_vdd/lib/src/generated/api.freezed.dart b/rust/bindings/dart_vdd/lib/src/generated/api.freezed.dart
index 69a145e8..180678f4 100644
--- a/rust/bindings/dart_vdd/lib/src/generated/api.freezed.dart
+++ b/rust/bindings/dart_vdd/lib/src/generated/api.freezed.dart
@@ -14,6 +14,816 @@ T _$identity<T>(T value) => value;
 final _privateConstructorUsedError = UnsupportedError(
     'It seems like you constructed your class using `MyClass._()`. This constructor is only meant to be used by freezed and you are not supposed to need it nor use it.\nPlease check the documentation here for more information: https://github.com/rrousselGit/freezed#adding-getters-and-methods-to-our-models');
 
+/// @nodoc
+mixin _$IpcError {
+  @optionalTypeArgs
+  TResult when<TResult extends Object?>({
+    required TResult Function(String field0) serDe,
+    required TResult Function(String field0) io,
+    required TResult Function(String field0) win,
+    required TResult Function(String field0) client,
+    required TResult Function() requestState,
+  }) =>
+      throw _privateConstructorUsedError;
+  @optionalTypeArgs
+  TResult? whenOrNull<TResult extends Object?>({
+    TResult? Function(String field0)? serDe,
+    TResult? Function(String field0)? io,
+    TResult? Function(String field0)? win,
+    TResult? Function(String field0)? client,
+    TResult? Function()? requestState,
+  }) =>
+      throw _privateConstructorUsedError;
+  @optionalTypeArgs
+  TResult maybeWhen<TResult extends Object?>({
+    TResult Function(String field0)? serDe,
+    TResult Function(String field0)? io,
+    TResult Function(String field0)? win,
+    TResult Function(String field0)? client,
+    TResult Function()? requestState,
+    required TResult orElse(),
+  }) =>
+      throw _privateConstructorUsedError;
+  @optionalTypeArgs
+  TResult map<TResult extends Object?>({
+    required TResult Function(IpcError_SerDe value) serDe,
+    required TResult Function(IpcError_Io value) io,
+    required TResult Function(IpcError_Win value) win,
+    required TResult Function(IpcError_Client value) client,
+    required TResult Function(IpcError_RequestState value) requestState,
+  }) =>
+      throw _privateConstructorUsedError;
+  @optionalTypeArgs
+  TResult? mapOrNull<TResult extends Object?>({
+    TResult? Function(IpcError_SerDe value)? serDe,
+    TResult? Function(IpcError_Io value)? io,
+    TResult? Function(IpcError_Win value)? win,
+    TResult? Function(IpcError_Client value)? client,
+    TResult? Function(IpcError_RequestState value)? requestState,
+  }) =>
+      throw _privateConstructorUsedError;
+  @optionalTypeArgs
+  TResult maybeMap<TResult extends Object?>({
+    TResult Function(IpcError_SerDe value)? serDe,
+    TResult Function(IpcError_Io value)? io,
+    TResult Function(IpcError_Win value)? win,
+    TResult Function(IpcError_Client value)? client,
+    TResult Function(IpcError_RequestState value)? requestState,
+    required TResult orElse(),
+  }) =>
+      throw _privateConstructorUsedError;
+}
+
+/// @nodoc
+abstract class $IpcErrorCopyWith<$Res> {
+  factory $IpcErrorCopyWith(IpcError value, $Res Function(IpcError) then) =
+      _$IpcErrorCopyWithImpl<$Res, IpcError>;
+}
+
+/// @nodoc
+class _$IpcErrorCopyWithImpl<$Res, $Val extends IpcError>
+    implements $IpcErrorCopyWith<$Res> {
+  _$IpcErrorCopyWithImpl(this._value, this._then);
+
+  // ignore: unused_field
+  final $Val _value;
+  // ignore: unused_field
+  final $Res Function($Val) _then;
+}
+
+/// @nodoc
+abstract class _$$IpcError_SerDeImplCopyWith<$Res> {
+  factory _$$IpcError_SerDeImplCopyWith(_$IpcError_SerDeImpl value,
+          $Res Function(_$IpcError_SerDeImpl) then) =
+      __$$IpcError_SerDeImplCopyWithImpl<$Res>;
+  @useResult
+  $Res call({String field0});
+}
+
+/// @nodoc
+class __$$IpcError_SerDeImplCopyWithImpl<$Res>
+    extends _$IpcErrorCopyWithImpl<$Res, _$IpcError_SerDeImpl>
+    implements _$$IpcError_SerDeImplCopyWith<$Res> {
+  __$$IpcError_SerDeImplCopyWithImpl(
+      _$IpcError_SerDeImpl _value, $Res Function(_$IpcError_SerDeImpl) _then)
+      : super(_value, _then);
+
+  @pragma('vm:prefer-inline')
+  @override
+  $Res call({
+    Object? field0 = null,
+  }) {
+    return _then(_$IpcError_SerDeImpl(
+      null == field0
+          ? _value.field0
+          : field0 // ignore: cast_nullable_to_non_nullable
+              as String,
+    ));
+  }
+}
+
+/// @nodoc
+
+class _$IpcError_SerDeImpl extends IpcError_SerDe {
+  const _$IpcError_SerDeImpl(this.field0) : super._();
+
+  @override
+  final String field0;
+
+  @override
+  String toString() {
+    return 'IpcError.serDe(field0: $field0)';
+  }
+
+  @override
+  bool operator ==(Object other) {
+    return identical(this, other) ||
+        (other.runtimeType == runtimeType &&
+            other is _$IpcError_SerDeImpl &&
+            (identical(other.field0, field0) || other.field0 == field0));
+  }
+
+  @override
+  int get hashCode => Object.hash(runtimeType, field0);
+
+  @JsonKey(ignore: true)
+  @override
+  @pragma('vm:prefer-inline')
+  _$$IpcError_SerDeImplCopyWith<_$IpcError_SerDeImpl> get copyWith =>
+      __$$IpcError_SerDeImplCopyWithImpl<_$IpcError_SerDeImpl>(
+          this, _$identity);
+
+  @override
+  @optionalTypeArgs
+  TResult when<TResult extends Object?>({
+    required TResult Function(String field0) serDe,
+    required TResult Function(String field0) io,
+    required TResult Function(String field0) win,
+    required TResult Function(String field0) client,
+    required TResult Function() requestState,
+  }) {
+    return serDe(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? whenOrNull<TResult extends Object?>({
+    TResult? Function(String field0)? serDe,
+    TResult? Function(String field0)? io,
+    TResult? Function(String field0)? win,
+    TResult? Function(String field0)? client,
+    TResult? Function()? requestState,
+  }) {
+    return serDe?.call(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeWhen<TResult extends Object?>({
+    TResult Function(String field0)? serDe,
+    TResult Function(String field0)? io,
+    TResult Function(String field0)? win,
+    TResult Function(String field0)? client,
+    TResult Function()? requestState,
+    required TResult orElse(),
+  }) {
+    if (serDe != null) {
+      return serDe(field0);
+    }
+    return orElse();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult map<TResult extends Object?>({
+    required TResult Function(IpcError_SerDe value) serDe,
+    required TResult Function(IpcError_Io value) io,
+    required TResult Function(IpcError_Win value) win,
+    required TResult Function(IpcError_Client value) client,
+    required TResult Function(IpcError_RequestState value) requestState,
+  }) {
+    return serDe(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? mapOrNull<TResult extends Object?>({
+    TResult? Function(IpcError_SerDe value)? serDe,
+    TResult? Function(IpcError_Io value)? io,
+    TResult? Function(IpcError_Win value)? win,
+    TResult? Function(IpcError_Client value)? client,
+    TResult? Function(IpcError_RequestState value)? requestState,
+  }) {
+    return serDe?.call(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeMap<TResult extends Object?>({
+    TResult Function(IpcError_SerDe value)? serDe,
+    TResult Function(IpcError_Io value)? io,
+    TResult Function(IpcError_Win value)? win,
+    TResult Function(IpcError_Client value)? client,
+    TResult Function(IpcError_RequestState value)? requestState,
+    required TResult orElse(),
+  }) {
+    if (serDe != null) {
+      return serDe(this);
+    }
+    return orElse();
+  }
+}
+
+abstract class IpcError_SerDe extends IpcError {
+  const factory IpcError_SerDe(final String field0) = _$IpcError_SerDeImpl;
+  const IpcError_SerDe._() : super._();
+
+  String get field0;
+  @JsonKey(ignore: true)
+  _$$IpcError_SerDeImplCopyWith<_$IpcError_SerDeImpl> get copyWith =>
+      throw _privateConstructorUsedError;
+}
+
+/// @nodoc
+abstract class _$$IpcError_IoImplCopyWith<$Res> {
+  factory _$$IpcError_IoImplCopyWith(
+          _$IpcError_IoImpl value, $Res Function(_$IpcError_IoImpl) then) =
+      __$$IpcError_IoImplCopyWithImpl<$Res>;
+  @useResult
+  $Res call({String field0});
+}
+
+/// @nodoc
+class __$$IpcError_IoImplCopyWithImpl<$Res>
+    extends _$IpcErrorCopyWithImpl<$Res, _$IpcError_IoImpl>
+    implements _$$IpcError_IoImplCopyWith<$Res> {
+  __$$IpcError_IoImplCopyWithImpl(
+      _$IpcError_IoImpl _value, $Res Function(_$IpcError_IoImpl) _then)
+      : super(_value, _then);
+
+  @pragma('vm:prefer-inline')
+  @override
+  $Res call({
+    Object? field0 = null,
+  }) {
+    return _then(_$IpcError_IoImpl(
+      null == field0
+          ? _value.field0
+          : field0 // ignore: cast_nullable_to_non_nullable
+              as String,
+    ));
+  }
+}
+
+/// @nodoc
+
+class _$IpcError_IoImpl extends IpcError_Io {
+  const _$IpcError_IoImpl(this.field0) : super._();
+
+  @override
+  final String field0;
+
+  @override
+  String toString() {
+    return 'IpcError.io(field0: $field0)';
+  }
+
+  @override
+  bool operator ==(Object other) {
+    return identical(this, other) ||
+        (other.runtimeType == runtimeType &&
+            other is _$IpcError_IoImpl &&
+            (identical(other.field0, field0) || other.field0 == field0));
+  }
+
+  @override
+  int get hashCode => Object.hash(runtimeType, field0);
+
+  @JsonKey(ignore: true)
+  @override
+  @pragma('vm:prefer-inline')
+  _$$IpcError_IoImplCopyWith<_$IpcError_IoImpl> get copyWith =>
+      __$$IpcError_IoImplCopyWithImpl<_$IpcError_IoImpl>(this, _$identity);
+
+  @override
+  @optionalTypeArgs
+  TResult when<TResult extends Object?>({
+    required TResult Function(String field0) serDe,
+    required TResult Function(String field0) io,
+    required TResult Function(String field0) win,
+    required TResult Function(String field0) client,
+    required TResult Function() requestState,
+  }) {
+    return io(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? whenOrNull<TResult extends Object?>({
+    TResult? Function(String field0)? serDe,
+    TResult? Function(String field0)? io,
+    TResult? Function(String field0)? win,
+    TResult? Function(String field0)? client,
+    TResult? Function()? requestState,
+  }) {
+    return io?.call(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeWhen<TResult extends Object?>({
+    TResult Function(String field0)? serDe,
+    TResult Function(String field0)? io,
+    TResult Function(String field0)? win,
+    TResult Function(String field0)? client,
+    TResult Function()? requestState,
+    required TResult orElse(),
+  }) {
+    if (io != null) {
+      return io(field0);
+    }
+    return orElse();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult map<TResult extends Object?>({
+    required TResult Function(IpcError_SerDe value) serDe,
+    required TResult Function(IpcError_Io value) io,
+    required TResult Function(IpcError_Win value) win,
+    required TResult Function(IpcError_Client value) client,
+    required TResult Function(IpcError_RequestState value) requestState,
+  }) {
+    return io(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? mapOrNull<TResult extends Object?>({
+    TResult? Function(IpcError_SerDe value)? serDe,
+    TResult? Function(IpcError_Io value)? io,
+    TResult? Function(IpcError_Win value)? win,
+    TResult? Function(IpcError_Client value)? client,
+    TResult? Function(IpcError_RequestState value)? requestState,
+  }) {
+    return io?.call(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeMap<TResult extends Object?>({
+    TResult Function(IpcError_SerDe value)? serDe,
+    TResult Function(IpcError_Io value)? io,
+    TResult Function(IpcError_Win value)? win,
+    TResult Function(IpcError_Client value)? client,
+    TResult Function(IpcError_RequestState value)? requestState,
+    required TResult orElse(),
+  }) {
+    if (io != null) {
+      return io(this);
+    }
+    return orElse();
+  }
+}
+
+abstract class IpcError_Io extends IpcError {
+  const factory IpcError_Io(final String field0) = _$IpcError_IoImpl;
+  const IpcError_Io._() : super._();
+
+  String get field0;
+  @JsonKey(ignore: true)
+  _$$IpcError_IoImplCopyWith<_$IpcError_IoImpl> get copyWith =>
+      throw _privateConstructorUsedError;
+}
+
+/// @nodoc
+abstract class _$$IpcError_WinImplCopyWith<$Res> {
+  factory _$$IpcError_WinImplCopyWith(
+          _$IpcError_WinImpl value, $Res Function(_$IpcError_WinImpl) then) =
+      __$$IpcError_WinImplCopyWithImpl<$Res>;
+  @useResult
+  $Res call({String field0});
+}
+
+/// @nodoc
+class __$$IpcError_WinImplCopyWithImpl<$Res>
+    extends _$IpcErrorCopyWithImpl<$Res, _$IpcError_WinImpl>
+    implements _$$IpcError_WinImplCopyWith<$Res> {
+  __$$IpcError_WinImplCopyWithImpl(
+      _$IpcError_WinImpl _value, $Res Function(_$IpcError_WinImpl) _then)
+      : super(_value, _then);
+
+  @pragma('vm:prefer-inline')
+  @override
+  $Res call({
+    Object? field0 = null,
+  }) {
+    return _then(_$IpcError_WinImpl(
+      null == field0
+          ? _value.field0
+          : field0 // ignore: cast_nullable_to_non_nullable
+              as String,
+    ));
+  }
+}
+
+/// @nodoc
+
+class _$IpcError_WinImpl extends IpcError_Win {
+  const _$IpcError_WinImpl(this.field0) : super._();
+
+  @override
+  final String field0;
+
+  @override
+  String toString() {
+    return 'IpcError.win(field0: $field0)';
+  }
+
+  @override
+  bool operator ==(Object other) {
+    return identical(this, other) ||
+        (other.runtimeType == runtimeType &&
+            other is _$IpcError_WinImpl &&
+            (identical(other.field0, field0) || other.field0 == field0));
+  }
+
+  @override
+  int get hashCode => Object.hash(runtimeType, field0);
+
+  @JsonKey(ignore: true)
+  @override
+  @pragma('vm:prefer-inline')
+  _$$IpcError_WinImplCopyWith<_$IpcError_WinImpl> get copyWith =>
+      __$$IpcError_WinImplCopyWithImpl<_$IpcError_WinImpl>(this, _$identity);
+
+  @override
+  @optionalTypeArgs
+  TResult when<TResult extends Object?>({
+    required TResult Function(String field0) serDe,
+    required TResult Function(String field0) io,
+    required TResult Function(String field0) win,
+    required TResult Function(String field0) client,
+    required TResult Function() requestState,
+  }) {
+    return win(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? whenOrNull<TResult extends Object?>({
+    TResult? Function(String field0)? serDe,
+    TResult? Function(String field0)? io,
+    TResult? Function(String field0)? win,
+    TResult? Function(String field0)? client,
+    TResult? Function()? requestState,
+  }) {
+    return win?.call(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeWhen<TResult extends Object?>({
+    TResult Function(String field0)? serDe,
+    TResult Function(String field0)? io,
+    TResult Function(String field0)? win,
+    TResult Function(String field0)? client,
+    TResult Function()? requestState,
+    required TResult orElse(),
+  }) {
+    if (win != null) {
+      return win(field0);
+    }
+    return orElse();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult map<TResult extends Object?>({
+    required TResult Function(IpcError_SerDe value) serDe,
+    required TResult Function(IpcError_Io value) io,
+    required TResult Function(IpcError_Win value) win,
+    required TResult Function(IpcError_Client value) client,
+    required TResult Function(IpcError_RequestState value) requestState,
+  }) {
+    return win(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? mapOrNull<TResult extends Object?>({
+    TResult? Function(IpcError_SerDe value)? serDe,
+    TResult? Function(IpcError_Io value)? io,
+    TResult? Function(IpcError_Win value)? win,
+    TResult? Function(IpcError_Client value)? client,
+    TResult? Function(IpcError_RequestState value)? requestState,
+  }) {
+    return win?.call(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeMap<TResult extends Object?>({
+    TResult Function(IpcError_SerDe value)? serDe,
+    TResult Function(IpcError_Io value)? io,
+    TResult Function(IpcError_Win value)? win,
+    TResult Function(IpcError_Client value)? client,
+    TResult Function(IpcError_RequestState value)? requestState,
+    required TResult orElse(),
+  }) {
+    if (win != null) {
+      return win(this);
+    }
+    return orElse();
+  }
+}
+
+abstract class IpcError_Win extends IpcError {
+  const factory IpcError_Win(final String field0) = _$IpcError_WinImpl;
+  const IpcError_Win._() : super._();
+
+  String get field0;
+  @JsonKey(ignore: true)
+  _$$IpcError_WinImplCopyWith<_$IpcError_WinImpl> get copyWith =>
+      throw _privateConstructorUsedError;
+}
+
+/// @nodoc
+abstract class _$$IpcError_ClientImplCopyWith<$Res> {
+  factory _$$IpcError_ClientImplCopyWith(_$IpcError_ClientImpl value,
+          $Res Function(_$IpcError_ClientImpl) then) =
+      __$$IpcError_ClientImplCopyWithImpl<$Res>;
+  @useResult
+  $Res call({String field0});
+}
+
+/// @nodoc
+class __$$IpcError_ClientImplCopyWithImpl<$Res>
+    extends _$IpcErrorCopyWithImpl<$Res, _$IpcError_ClientImpl>
+    implements _$$IpcError_ClientImplCopyWith<$Res> {
+  __$$IpcError_ClientImplCopyWithImpl(
+      _$IpcError_ClientImpl _value, $Res Function(_$IpcError_ClientImpl) _then)
+      : super(_value, _then);
+
+  @pragma('vm:prefer-inline')
+  @override
+  $Res call({
+    Object? field0 = null,
+  }) {
+    return _then(_$IpcError_ClientImpl(
+      null == field0
+          ? _value.field0
+          : field0 // ignore: cast_nullable_to_non_nullable
+              as String,
+    ));
+  }
+}
+
+/// @nodoc
+
+class _$IpcError_ClientImpl extends IpcError_Client {
+  const _$IpcError_ClientImpl(this.field0) : super._();
+
+  @override
+  final String field0;
+
+  @override
+  String toString() {
+    return 'IpcError.client(field0: $field0)';
+  }
+
+  @override
+  bool operator ==(Object other) {
+    return identical(this, other) ||
+        (other.runtimeType == runtimeType &&
+            other is _$IpcError_ClientImpl &&
+            (identical(other.field0, field0) || other.field0 == field0));
+  }
+
+  @override
+  int get hashCode => Object.hash(runtimeType, field0);
+
+  @JsonKey(ignore: true)
+  @override
+  @pragma('vm:prefer-inline')
+  _$$IpcError_ClientImplCopyWith<_$IpcError_ClientImpl> get copyWith =>
+      __$$IpcError_ClientImplCopyWithImpl<_$IpcError_ClientImpl>(
+          this, _$identity);
+
+  @override
+  @optionalTypeArgs
+  TResult when<TResult extends Object?>({
+    required TResult Function(String field0) serDe,
+    required TResult Function(String field0) io,
+    required TResult Function(String field0) win,
+    required TResult Function(String field0) client,
+    required TResult Function() requestState,
+  }) {
+    return client(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? whenOrNull<TResult extends Object?>({
+    TResult? Function(String field0)? serDe,
+    TResult? Function(String field0)? io,
+    TResult? Function(String field0)? win,
+    TResult? Function(String field0)? client,
+    TResult? Function()? requestState,
+  }) {
+    return client?.call(field0);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeWhen<TResult extends Object?>({
+    TResult Function(String field0)? serDe,
+    TResult Function(String field0)? io,
+    TResult Function(String field0)? win,
+    TResult Function(String field0)? client,
+    TResult Function()? requestState,
+    required TResult orElse(),
+  }) {
+    if (client != null) {
+      return client(field0);
+    }
+    return orElse();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult map<TResult extends Object?>({
+    required TResult Function(IpcError_SerDe value) serDe,
+    required TResult Function(IpcError_Io value) io,
+    required TResult Function(IpcError_Win value) win,
+    required TResult Function(IpcError_Client value) client,
+    required TResult Function(IpcError_RequestState value) requestState,
+  }) {
+    return client(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? mapOrNull<TResult extends Object?>({
+    TResult? Function(IpcError_SerDe value)? serDe,
+    TResult? Function(IpcError_Io value)? io,
+    TResult? Function(IpcError_Win value)? win,
+    TResult? Function(IpcError_Client value)? client,
+    TResult? Function(IpcError_RequestState value)? requestState,
+  }) {
+    return client?.call(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeMap<TResult extends Object?>({
+    TResult Function(IpcError_SerDe value)? serDe,
+    TResult Function(IpcError_Io value)? io,
+    TResult Function(IpcError_Win value)? win,
+    TResult Function(IpcError_Client value)? client,
+    TResult Function(IpcError_RequestState value)? requestState,
+    required TResult orElse(),
+  }) {
+    if (client != null) {
+      return client(this);
+    }
+    return orElse();
+  }
+}
+
+abstract class IpcError_Client extends IpcError {
+  const factory IpcError_Client(final String field0) = _$IpcError_ClientImpl;
+  const IpcError_Client._() : super._();
+
+  String get field0;
+  @JsonKey(ignore: true)
+  _$$IpcError_ClientImplCopyWith<_$IpcError_ClientImpl> get copyWith =>
+      throw _privateConstructorUsedError;
+}
+
+/// @nodoc
+abstract class _$$IpcError_RequestStateImplCopyWith<$Res> {
+  factory _$$IpcError_RequestStateImplCopyWith(
+          _$IpcError_RequestStateImpl value,
+          $Res Function(_$IpcError_RequestStateImpl) then) =
+      __$$IpcError_RequestStateImplCopyWithImpl<$Res>;
+}
+
+/// @nodoc
+class __$$IpcError_RequestStateImplCopyWithImpl<$Res>
+    extends _$IpcErrorCopyWithImpl<$Res, _$IpcError_RequestStateImpl>
+    implements _$$IpcError_RequestStateImplCopyWith<$Res> {
+  __$$IpcError_RequestStateImplCopyWithImpl(_$IpcError_RequestStateImpl _value,
+      $Res Function(_$IpcError_RequestStateImpl) _then)
+      : super(_value, _then);
+}
+
+/// @nodoc
+
+class _$IpcError_RequestStateImpl extends IpcError_RequestState {
+  const _$IpcError_RequestStateImpl() : super._();
+
+  @override
+  String toString() {
+    return 'IpcError.requestState()';
+  }
+
+  @override
+  bool operator ==(Object other) {
+    return identical(this, other) ||
+        (other.runtimeType == runtimeType &&
+            other is _$IpcError_RequestStateImpl);
+  }
+
+  @override
+  int get hashCode => runtimeType.hashCode;
+
+  @override
+  @optionalTypeArgs
+  TResult when<TResult extends Object?>({
+    required TResult Function(String field0) serDe,
+    required TResult Function(String field0) io,
+    required TResult Function(String field0) win,
+    required TResult Function(String field0) client,
+    required TResult Function() requestState,
+  }) {
+    return requestState();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? whenOrNull<TResult extends Object?>({
+    TResult? Function(String field0)? serDe,
+    TResult? Function(String field0)? io,
+    TResult? Function(String field0)? win,
+    TResult? Function(String field0)? client,
+    TResult? Function()? requestState,
+  }) {
+    return requestState?.call();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeWhen<TResult extends Object?>({
+    TResult Function(String field0)? serDe,
+    TResult Function(String field0)? io,
+    TResult Function(String field0)? win,
+    TResult Function(String field0)? client,
+    TResult Function()? requestState,
+    required TResult orElse(),
+  }) {
+    if (requestState != null) {
+      return requestState();
+    }
+    return orElse();
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult map<TResult extends Object?>({
+    required TResult Function(IpcError_SerDe value) serDe,
+    required TResult Function(IpcError_Io value) io,
+    required TResult Function(IpcError_Win value) win,
+    required TResult Function(IpcError_Client value) client,
+    required TResult Function(IpcError_RequestState value) requestState,
+  }) {
+    return requestState(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult? mapOrNull<TResult extends Object?>({
+    TResult? Function(IpcError_SerDe value)? serDe,
+    TResult? Function(IpcError_Io value)? io,
+    TResult? Function(IpcError_Win value)? win,
+    TResult? Function(IpcError_Client value)? client,
+    TResult? Function(IpcError_RequestState value)? requestState,
+  }) {
+    return requestState?.call(this);
+  }
+
+  @override
+  @optionalTypeArgs
+  TResult maybeMap<TResult extends Object?>({
+    TResult Function(IpcError_SerDe value)? serDe,
+    TResult Function(IpcError_Io value)? io,
+    TResult Function(IpcError_Win value)? win,
+    TResult Function(IpcError_Client value)? client,
+    TResult Function(IpcError_RequestState value)? requestState,
+    required TResult orElse(),
+  }) {
+    if (requestState != null) {
+      return requestState(this);
+    }
+    return orElse();
+  }
+}
+
+abstract class IpcError_RequestState extends IpcError {
+  const factory IpcError_RequestState() = _$IpcError_RequestStateImpl;
+  const IpcError_RequestState._() : super._();
+}
+
 /// @nodoc
 mixin _$Mode {
   int get width => throw _privateConstructorUsedError;
diff --git a/rust/bindings/dart_vdd/lib/src/generated/frb_generated.dart b/rust/bindings/dart_vdd/lib/src/generated/frb_generated.dart
index 219ed5f7..02eeb9e1 100644
--- a/rust/bindings/dart_vdd/lib/src/generated/frb_generated.dart
+++ b/rust/bindings/dart_vdd/lib/src/generated/frb_generated.dart
@@ -102,7 +102,7 @@ abstract class RustLibApi extends BaseApi {
   Future<List<Monitor>> virtualDisplayDriverState(
       {required VirtualDisplayDriver that, dynamic hint});
 
-  Future<Stream<List<Monitor>>> virtualDisplayDriverStream(
+  Stream<List<Monitor>> virtualDisplayDriverStream(
       {required VirtualDisplayDriver that, dynamic hint});
 
   RustArcIncrementStrongCountFnType
@@ -143,7 +143,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       },
       codec: SseCodec(
         decodeSuccessData: sse_decode_unit,
-        decodeErrorData: sse_decode_AnyhowException,
+        decodeErrorData: sse_decode_ipc_error,
       ),
       constMeta: kVirtualDisplayDriverAddMonitorConstMeta,
       argValues: [that, name, enabled, modes],
@@ -170,7 +170,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       codec: SseCodec(
         decodeSuccessData:
             sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver,
-        decodeErrorData: sse_decode_AnyhowException,
+        decodeErrorData: sse_decode_ipc_error,
       ),
       constMeta: kVirtualDisplayDriverNewConstMeta,
       argValues: [pipeName],
@@ -197,7 +197,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       },
       codec: SseCodec(
         decodeSuccessData: sse_decode_unit,
-        decodeErrorData: sse_decode_AnyhowException,
+        decodeErrorData: sse_decode_ipc_error,
       ),
       constMeta: kVirtualDisplayDriverNotifyConstMeta,
       argValues: [that],
@@ -224,7 +224,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       },
       codec: SseCodec(
         decodeSuccessData: sse_decode_unit,
-        decodeErrorData: sse_decode_AnyhowException,
+        decodeErrorData: sse_decode_ipc_error,
       ),
       constMeta: kVirtualDisplayDriverPersistConstMeta,
       argValues: [that],
@@ -320,7 +320,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       },
       codec: SseCodec(
         decodeSuccessData: sse_decode_unit,
-        decodeErrorData: sse_decode_AnyhowException,
+        decodeErrorData: sse_decode_ipc_error,
       ),
       constMeta: kVirtualDisplayDriverSetMonitorConstMeta,
       argValues: [that, id, enabled, name, modes],
@@ -351,7 +351,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       },
       codec: SseCodec(
         decodeSuccessData: sse_decode_unit,
-        decodeErrorData: sse_decode_AnyhowException,
+        decodeErrorData: sse_decode_ipc_error,
       ),
       constMeta: kVirtualDisplayDriverSetMonitorsConstMeta,
       argValues: [that, monitors],
@@ -394,17 +394,16 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       );
 
   @override
-  Future<Stream<List<Monitor>>> virtualDisplayDriverStream(
-      {required VirtualDisplayDriver that, dynamic hint}) async {
+  Stream<List<Monitor>> virtualDisplayDriverStream(
+      {required VirtualDisplayDriver that, dynamic hint}) {
     final sink = RustStreamSink<List<Monitor>>();
-    await handler.executeNormal(NormalTask(
-      callFfi: (port_) {
+    handler.executeSync(SyncTask(
+      callFfi: () {
         final serializer = SseSerializer(generalizedFrbRustBinding);
         sse_encode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
             that, serializer);
         sse_encode_StreamSink_list_monitor_Sse(sink, serializer);
-        pdeCallFfi(generalizedFrbRustBinding, serializer,
-            funcId: 3, port: port_);
+        return pdeCallFfi(generalizedFrbRustBinding, serializer, funcId: 3)!;
       },
       codec: SseCodec(
         decodeSuccessData: sse_decode_unit,
@@ -431,12 +430,6 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       get rust_arc_decrement_strong_count_VirtualDisplayDriver => wire
           .rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver;
 
-  @protected
-  AnyhowException dco_decode_AnyhowException(dynamic raw) {
-    // Codec=Dco (DartCObject based), see doc to use other codecs
-    return AnyhowException(raw as String);
-  }
-
   @protected
   VirtualDisplayDriver
       dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
@@ -494,6 +487,33 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return raw as bool;
   }
 
+  @protected
+  IpcError dco_decode_ipc_error(dynamic raw) {
+    // Codec=Dco (DartCObject based), see doc to use other codecs
+    switch (raw[0]) {
+      case 0:
+        return IpcError_SerDe(
+          dco_decode_String(raw[1]),
+        );
+      case 1:
+        return IpcError_Io(
+          dco_decode_String(raw[1]),
+        );
+      case 2:
+        return IpcError_Win(
+          dco_decode_String(raw[1]),
+        );
+      case 3:
+        return IpcError_Client(
+          dco_decode_String(raw[1]),
+        );
+      case 4:
+        return IpcError_RequestState();
+      default:
+        throw Exception("unreachable");
+    }
+  }
+
   @protected
   List<Mode> dco_decode_list_mode(dynamic raw) {
     // Codec=Dco (DartCObject based), see doc to use other codecs
@@ -593,13 +613,6 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return dcoDecodeI64OrU64(raw);
   }
 
-  @protected
-  AnyhowException sse_decode_AnyhowException(SseDeserializer deserializer) {
-    // Codec=Sse (Serialization based), see doc to use other codecs
-    var inner = sse_decode_String(deserializer);
-    return AnyhowException(inner);
-  }
-
   @protected
   VirtualDisplayDriver
       sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
@@ -662,6 +675,31 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return (sse_decode_bool(deserializer));
   }
 
+  @protected
+  IpcError sse_decode_ipc_error(SseDeserializer deserializer) {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+
+    var tag_ = sse_decode_i_32(deserializer);
+    switch (tag_) {
+      case 0:
+        var var_field0 = sse_decode_String(deserializer);
+        return IpcError_SerDe(var_field0);
+      case 1:
+        var var_field0 = sse_decode_String(deserializer);
+        return IpcError_Io(var_field0);
+      case 2:
+        var var_field0 = sse_decode_String(deserializer);
+        return IpcError_Win(var_field0);
+      case 3:
+        var var_field0 = sse_decode_String(deserializer);
+        return IpcError_Client(var_field0);
+      case 4:
+        return IpcError_RequestState();
+      default:
+        throw UnimplementedError('');
+    }
+  }
+
   @protected
   List<Mode> sse_decode_list_mode(SseDeserializer deserializer) {
     // Codec=Sse (Serialization based), see doc to use other codecs
@@ -790,13 +828,6 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return deserializer.buffer.getInt32();
   }
 
-  @protected
-  void sse_encode_AnyhowException(
-      AnyhowException self, SseSerializer serializer) {
-    // Codec=Sse (Serialization based), see doc to use other codecs
-    throw UnimplementedError('Unreachable ()');
-  }
-
   @protected
   void
       sse_encode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
@@ -859,6 +890,27 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     sse_encode_bool(self, serializer);
   }
 
+  @protected
+  void sse_encode_ipc_error(IpcError self, SseSerializer serializer) {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    switch (self) {
+      case IpcError_SerDe(field0: final field0):
+        sse_encode_i_32(0, serializer);
+        sse_encode_String(field0, serializer);
+      case IpcError_Io(field0: final field0):
+        sse_encode_i_32(1, serializer);
+        sse_encode_String(field0, serializer);
+      case IpcError_Win(field0: final field0):
+        sse_encode_i_32(2, serializer);
+        sse_encode_String(field0, serializer);
+      case IpcError_Client(field0: final field0):
+        sse_encode_i_32(3, serializer);
+        sse_encode_String(field0, serializer);
+      case IpcError_RequestState():
+        sse_encode_i_32(4, serializer);
+    }
+  }
+
   @protected
   void sse_encode_list_mode(List<Mode> self, SseSerializer serializer) {
     // Codec=Sse (Serialization based), see doc to use other codecs
diff --git a/rust/bindings/dart_vdd/lib/src/generated/frb_generated.io.dart b/rust/bindings/dart_vdd/lib/src/generated/frb_generated.io.dart
index f94265b5..87b97658 100644
--- a/rust/bindings/dart_vdd/lib/src/generated/frb_generated.io.dart
+++ b/rust/bindings/dart_vdd/lib/src/generated/frb_generated.io.dart
@@ -1,5 +1,5 @@
 // This file is automatically generated, so please do not edit it.
-// Generated by `flutter_rust_bridge`@ 2.0.0-dev.28.
+// Generated by `flutter_rust_bridge`@ 2.0.0-dev.31.
 
 // ignore_for_file: unused_import, unused_element, unnecessary_import, duplicate_ignore, invalid_use_of_internal_member, annotate_overrides, non_constant_identifier_names, curly_braces_in_flow_control_structures, prefer_const_literals_to_create_immutables, unused_field
 
@@ -27,6 +27,11 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
           dynamic raw);
 
+  @protected
+  VirtualDisplayDriver
+      dco_decode_Auto_RefMut_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
+          dynamic raw);
+
   @protected
   VirtualDisplayDriver
       dco_decode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
@@ -37,6 +42,10 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       dco_decode_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
           dynamic raw);
 
+  @protected
+  RustStreamSink<List<Monitor>> dco_decode_StreamSink_list_monitor_Sse(
+      dynamic raw);
+
   @protected
   String dco_decode_String(dynamic raw);
 
@@ -46,6 +55,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   bool dco_decode_box_autoadd_bool(dynamic raw);
 
+  @protected
+  IpcError dco_decode_ipc_error(dynamic raw);
+
   @protected
   List<Mode> dco_decode_list_mode(dynamic raw);
 
@@ -93,6 +105,11 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
           SseDeserializer deserializer);
 
+  @protected
+  VirtualDisplayDriver
+      sse_decode_Auto_RefMut_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
+          SseDeserializer deserializer);
+
   @protected
   VirtualDisplayDriver
       sse_decode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
@@ -103,6 +120,10 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_decode_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
           SseDeserializer deserializer);
 
+  @protected
+  RustStreamSink<List<Monitor>> sse_decode_StreamSink_list_monitor_Sse(
+      SseDeserializer deserializer);
+
   @protected
   String sse_decode_String(SseDeserializer deserializer);
 
@@ -112,6 +133,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   bool sse_decode_box_autoadd_bool(SseDeserializer deserializer);
 
+  @protected
+  IpcError sse_decode_ipc_error(SseDeserializer deserializer);
+
   @protected
   List<Mode> sse_decode_list_mode(SseDeserializer deserializer);
 
@@ -162,6 +186,11 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_encode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
           VirtualDisplayDriver self, SseSerializer serializer);
 
+  @protected
+  void
+      sse_encode_Auto_RefMut_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
+          VirtualDisplayDriver self, SseSerializer serializer);
+
   @protected
   void
       sse_encode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
@@ -172,6 +201,10 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_encode_RustOpaque_flutter_rust_bridgefor_generatedrust_asyncRwLockVirtualDisplayDriver(
           VirtualDisplayDriver self, SseSerializer serializer);
 
+  @protected
+  void sse_encode_StreamSink_list_monitor_Sse(
+      RustStreamSink<List<Monitor>> self, SseSerializer serializer);
+
   @protected
   void sse_encode_String(String self, SseSerializer serializer);
 
@@ -181,6 +214,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   void sse_encode_box_autoadd_bool(bool self, SseSerializer serializer);
 
+  @protected
+  void sse_encode_ipc_error(IpcError self, SseSerializer serializer);
+
   @protected
   void sse_encode_list_mode(List<Mode> self, SseSerializer serializer);
 
diff --git a/rust/bindings/dart_vdd/rust/src/api.rs b/rust/bindings/dart_vdd/rust/src/api.rs
index eee50ca4..4af79d4e 100644
--- a/rust/bindings/dart_vdd/rust/src/api.rs
+++ b/rust/bindings/dart_vdd/rust/src/api.rs
@@ -1,4 +1,4 @@
-use driver_ipc::{ClientCommand, DriverClient, EventCommand, Result};
+use driver_ipc::{ClientCommand, DriverClient, EventCommand};
 pub use driver_ipc::{Mode, Monitor};
 use flutter_rust_bridge::frb;
 
@@ -19,6 +19,26 @@ pub struct _Mode {
     pub refresh_rates: Vec<u32>,
 }
 
+pub enum IpcError {
+    SerDe(String),
+    Io(String),
+    Win(String),
+    Client(String),
+    RequestState,
+}
+
+impl From<driver_ipc::IpcError> for IpcError {
+    fn from(e: driver_ipc::IpcError) -> Self {
+        match e {
+            driver_ipc::IpcError::SerDe(e) => IpcError::SerDe(e.to_string()),
+            driver_ipc::IpcError::Io(e) => IpcError::Io(e.to_string()),
+            driver_ipc::IpcError::Win(e) => IpcError::Win(e.to_string()),
+            driver_ipc::IpcError::Client(e) => IpcError::Client(e.to_string()),
+            driver_ipc::IpcError::RequestState => IpcError::RequestState,
+        }
+    }
+}
+
 #[frb(opaque)]
 pub struct VirtualDisplayDriver {
     client: DriverClient,
@@ -26,7 +46,7 @@ pub struct VirtualDisplayDriver {
 
 impl VirtualDisplayDriver {
     #[frb(sync)]
-    pub fn new(_pipe_name: Option<String>) -> Result<VirtualDisplayDriver> {
+    pub fn new(_pipe_name: Option<String>) -> Result<VirtualDisplayDriver, IpcError> {
         let vdd = VirtualDisplayDriver {
             client: DriverClient::new()?,
         };
@@ -47,7 +67,7 @@ impl VirtualDisplayDriver {
     /// current state of the driver.
     ///
     /// After calling, will instantly emit the current state of the driver.
-    #[frb(getter)]
+    #[frb(getter, sync)]
     pub fn stream(&self, sink: StreamSink<Vec<Monitor>>) {
         self.client.set_receiver(None::<fn()>, move |command| {
             if let ClientCommand::Event(EventCommand::Changed(data)) = command {
@@ -61,8 +81,9 @@ impl VirtualDisplayDriver {
     /// Set the state of the provided monitors.
     ///
     /// Each monitor with a matching ID will be updated to the provided state.
-    pub fn set_monitors(&mut self, monitors: Vec<Monitor>) -> Result<()> {
-        self.client.set_monitors(&monitors)
+    pub fn set_monitors(&mut self, monitors: Vec<Monitor>) -> Result<(), IpcError> {
+        self.client.set_monitors(&monitors)?;
+        Ok(())
     }
 
     /// Set the state of the monitor with the provided ID.
@@ -74,7 +95,7 @@ impl VirtualDisplayDriver {
         enabled: Option<bool>,
         name: Option<String>,
         modes: Option<Vec<Mode>>,
-    ) -> Result<()> {
+    ) -> Result<(), IpcError> {
         self.client.find_monitor_mut(id, |monitor| {
             if let Some(enabled) = enabled {
                 monitor.enabled = enabled;
@@ -96,7 +117,7 @@ impl VirtualDisplayDriver {
         name: Option<String>,
         enabled: bool,
         modes: Vec<Mode>,
-    ) -> Result<()> {
+    ) -> Result<(), IpcError> {
         let monitor = Monitor {
             id: self.client.new_id(None)?,
             name,
@@ -120,12 +141,14 @@ impl VirtualDisplayDriver {
     }
 
     /// Push in-memory changes to driver.
-    pub fn notify(&mut self) -> Result<()> {
-        self.client.notify()
+    pub fn notify(&mut self) -> Result<(), IpcError> {
+        self.client.notify()?;
+        Ok(())
     }
 
     /// Persist in-memory changes to user settings
-    pub fn persist(&mut self) -> Result<()> {
-        self.client.persist()
+    pub fn persist(&mut self) -> Result<(), IpcError> {
+        self.client.persist()?;
+        Ok(())
     }
 }
diff --git a/rust/bindings/dart_vdd/rust/src/frb_generated.rs b/rust/bindings/dart_vdd/rust/src/frb_generated.rs
index 476ac448..3f5accec 100644
--- a/rust/bindings/dart_vdd/rust/src/frb_generated.rs
+++ b/rust/bindings/dart_vdd/rust/src/frb_generated.rs
@@ -374,16 +374,15 @@ fn wire_VirtualDisplayDriver_state_impl(
     )
 }
 fn wire_VirtualDisplayDriver_stream_impl(
-    port_: flutter_rust_bridge::for_generated::MessagePort,
     ptr_: flutter_rust_bridge::for_generated::PlatformGeneralizedUint8ListPtr,
     rust_vec_len_: i32,
     data_len_: i32,
-) {
-    FLUTTER_RUST_BRIDGE_HANDLER.wrap_normal::<flutter_rust_bridge::for_generated::SseCodec, _, _>(
+) -> flutter_rust_bridge::for_generated::WireSyncRust2DartSse {
+    FLUTTER_RUST_BRIDGE_HANDLER.wrap_sync::<flutter_rust_bridge::for_generated::SseCodec, _>(
         flutter_rust_bridge::for_generated::TaskInfo {
             debug_name: "VirtualDisplayDriver_stream",
-            port: Some(port_),
-            mode: flutter_rust_bridge::for_generated::FfiCallMode::Normal,
+            port: None,
+            mode: flutter_rust_bridge::for_generated::FfiCallMode::Sync,
         },
         move || {
             let message = unsafe {
@@ -403,14 +402,12 @@ fn wire_VirtualDisplayDriver_stream_impl(
                 flutter_rust_bridge::for_generated::SseCodec,
             >>::sse_decode(&mut deserializer);
             deserializer.end();
-            move |context| {
-                transform_result_sse((move || {
-                    let api_that = api_that.rust_auto_opaque_decode_ref();
-                    Result::<_, ()>::Ok(crate::api::VirtualDisplayDriver::stream(
-                        &api_that, api_sink,
-                    ))
-                })())
-            }
+            transform_result_sse((move || {
+                let api_that = api_that.rust_auto_opaque_decode_ref();
+                Result::<_, ()>::Ok(crate::api::VirtualDisplayDriver::stream(
+                    &api_that, api_sink,
+                ))
+            })())
         },
     )
 }
@@ -442,13 +439,6 @@ flutter_rust_bridge::frb_generated_moi_arc_impl_value!(
 
 // Section: dart2rust
 
-impl SseDecode for flutter_rust_bridge::for_generated::anyhow::Error {
-    // Codec=Sse (Serialization based), see doc to use other codecs
-    fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
-        unreachable!("");
-    }
-}
-
 impl SseDecode for VirtualDisplayDriver {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
@@ -494,6 +484,37 @@ impl SseDecode for bool {
     }
 }
 
+impl SseDecode for crate::api::IpcError {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
+        let mut tag_ = <i32>::sse_decode(deserializer);
+        match tag_ {
+            0 => {
+                let mut var_field0 = <String>::sse_decode(deserializer);
+                return crate::api::IpcError::SerDe(var_field0);
+            }
+            1 => {
+                let mut var_field0 = <String>::sse_decode(deserializer);
+                return crate::api::IpcError::Io(var_field0);
+            }
+            2 => {
+                let mut var_field0 = <String>::sse_decode(deserializer);
+                return crate::api::IpcError::Win(var_field0);
+            }
+            3 => {
+                let mut var_field0 = <String>::sse_decode(deserializer);
+                return crate::api::IpcError::Client(var_field0);
+            }
+            4 => {
+                return crate::api::IpcError::RequestState;
+            }
+            _ => {
+                unimplemented!("");
+            }
+        }
+    }
+}
+
 impl SseDecode for Vec<crate::api::Mode> {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
@@ -655,7 +676,6 @@ fn pde_ffi_dispatcher_primary_impl(
         5 => wire_VirtualDisplayDriver_set_monitor_impl(port, ptr, rust_vec_len, data_len),
         4 => wire_VirtualDisplayDriver_set_monitors_impl(port, ptr, rust_vec_len, data_len),
         2 => wire_VirtualDisplayDriver_state_impl(port, ptr, rust_vec_len, data_len),
-        3 => wire_VirtualDisplayDriver_stream_impl(port, ptr, rust_vec_len, data_len),
         _ => unreachable!(),
     }
 }
@@ -669,6 +689,7 @@ fn pde_ffi_dispatcher_sync_impl(
     // Codec=Pde (Serialization + dispatch), see doc to use other codecs
     match func_id {
         1 => wire_VirtualDisplayDriver_new_impl(ptr, rust_vec_len, data_len),
+        3 => wire_VirtualDisplayDriver_stream_impl(ptr, rust_vec_len, data_len),
         _ => unreachable!(),
     }
 }
@@ -693,6 +714,32 @@ impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<VirtualDisplayDriver>> for Vir
     }
 }
 
+// Codec=Dco (DartCObject based), see doc to use other codecs
+impl flutter_rust_bridge::IntoDart for crate::api::IpcError {
+    fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
+        match self {
+            crate::api::IpcError::SerDe(field0) => {
+                [0.into_dart(), field0.into_into_dart().into_dart()].into_dart()
+            }
+            crate::api::IpcError::Io(field0) => {
+                [1.into_dart(), field0.into_into_dart().into_dart()].into_dart()
+            }
+            crate::api::IpcError::Win(field0) => {
+                [2.into_dart(), field0.into_into_dart().into_dart()].into_dart()
+            }
+            crate::api::IpcError::Client(field0) => {
+                [3.into_dart(), field0.into_into_dart().into_dart()].into_dart()
+            }
+            crate::api::IpcError::RequestState => [4.into_dart()].into_dart(),
+        }
+    }
+}
+impl flutter_rust_bridge::for_generated::IntoDartExceptPrimitive for crate::api::IpcError {}
+impl flutter_rust_bridge::IntoIntoDart<crate::api::IpcError> for crate::api::IpcError {
+    fn into_into_dart(self) -> crate::api::IpcError {
+        self
+    }
+}
 // Codec=Dco (DartCObject based), see doc to use other codecs
 impl flutter_rust_bridge::IntoDart for FrbWrapper<crate::api::Mode> {
     fn into_dart(self) -> flutter_rust_bridge::for_generated::DartAbi {
@@ -732,13 +779,6 @@ impl flutter_rust_bridge::IntoIntoDart<FrbWrapper<crate::api::Monitor>> for crat
     }
 }
 
-impl SseEncode for flutter_rust_bridge::for_generated::anyhow::Error {
-    // Codec=Sse (Serialization based), see doc to use other codecs
-    fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
-        <String>::sse_encode(format!("{:?}", self), serializer);
-    }
-}
-
 impl SseEncode for VirtualDisplayDriver {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
@@ -780,6 +820,33 @@ impl SseEncode for bool {
     }
 }
 
+impl SseEncode for crate::api::IpcError {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
+        match self {
+            crate::api::IpcError::SerDe(field0) => {
+                <i32>::sse_encode(0, serializer);
+                <String>::sse_encode(field0, serializer);
+            }
+            crate::api::IpcError::Io(field0) => {
+                <i32>::sse_encode(1, serializer);
+                <String>::sse_encode(field0, serializer);
+            }
+            crate::api::IpcError::Win(field0) => {
+                <i32>::sse_encode(2, serializer);
+                <String>::sse_encode(field0, serializer);
+            }
+            crate::api::IpcError::Client(field0) => {
+                <i32>::sse_encode(3, serializer);
+                <String>::sse_encode(field0, serializer);
+            }
+            crate::api::IpcError::RequestState => {
+                <i32>::sse_encode(4, serializer);
+            }
+        }
+    }
+}
+
 impl SseEncode for Vec<crate::api::Mode> {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {