mangayomi-mirror/lib/src/rust/frb_generated.dart
Moustapha Kodjo Amadou d5aecf66dc Fix #643
2026-01-26 17:28:25 +01:00

3445 lines
107 KiB
Dart

// This file is automatically generated, so please do not edit it.
// @generated by `flutter_rust_bridge`@ 2.11.1.
// 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
import 'api/epub.dart';
import 'api/image.dart';
import 'api/rhttp/client.dart';
import 'api/rhttp/error.dart';
import 'api/rhttp/http.dart';
import 'dart:async';
import 'dart:convert';
import 'frb_generated.dart';
import 'frb_generated.io.dart'
if (dart.library.js_interop) 'frb_generated.web.dart';
import 'lib.dart';
import 'package:flutter_rust_bridge/flutter_rust_bridge_for_generated.dart';
/// Main entrypoint of the Rust API
class RustLib extends BaseEntrypoint<RustLibApi, RustLibApiImpl, RustLibWire> {
@internal
static final instance = RustLib._();
RustLib._();
/// Initialize flutter_rust_bridge
static Future<void> init({
RustLibApi? api,
BaseHandler? handler,
ExternalLibrary? externalLibrary,
bool forceSameCodegenVersion = true,
}) async {
await instance.initImpl(
api: api,
handler: handler,
externalLibrary: externalLibrary,
forceSameCodegenVersion: forceSameCodegenVersion,
);
}
/// Initialize flutter_rust_bridge in mock mode.
/// No libraries for FFI are loaded.
static void initMock({required RustLibApi api}) {
instance.initMockImpl(api: api);
}
/// Dispose flutter_rust_bridge
///
/// The call to this function is optional, since flutter_rust_bridge (and everything else)
/// is automatically disposed when the app stops.
static void dispose() => instance.disposeImpl();
@override
ApiImplConstructor<RustLibApiImpl, RustLibWire> get apiImplConstructor =>
RustLibApiImpl.new;
@override
WireConstructor<RustLibWire> get wireConstructor =>
RustLibWire.fromExternalLibrary;
@override
Future<void> executeRustInitializers() async {}
@override
ExternalLibraryLoaderConfig get defaultExternalLibraryLoaderConfig =>
kDefaultExternalLibraryLoaderConfig;
@override
String get codegenVersion => '2.11.1';
@override
int get rustContentHash => 2140434025;
static const kDefaultExternalLibraryLoaderConfig =
ExternalLibraryLoaderConfig(
stem: 'rust_lib_mangayomi',
ioDirectory: 'rust/target/release/',
webPrefix: 'pkg/',
);
}
abstract class RustLibApi extends BaseApi {
Future<void> crateApiRhttpHttpCancelRequest({
required CancellationToken token,
});
Future<void> crateApiRhttpHttpCancelRunningRequests({
required RequestClient client,
});
Future<ClientSettings> crateApiRhttpClientClientSettingsDefault();
DnsSettings crateApiRhttpClientCreateDynamicResolverSync({
required FutureOr<List<String>> Function(String) resolver,
});
DnsSettings crateApiRhttpClientCreateStaticResolverSync({
required StaticDnsSettings settings,
});
Future<String> crateApiEpubGetChapterContent({
required String epubPath,
required String chapterPath,
});
Stream<Uint8List> crateApiRhttpHttpMakeHttpRequestReceiveStream({
RequestClient? client,
ClientSettings? settings,
required HttpMethod method,
required String url,
List<(String, String)>? query,
HttpHeaders? headers,
Uint8List? body,
required FutureOr<void> Function(HttpResponse) onResponse,
required FutureOr<void> Function(RhttpError) onError,
required FutureOr<void> Function(CancellationToken) onCancelToken,
required bool cancelable,
});
Future<EpubNovel> crateApiEpubParseEpubFromBytes({
required List<int> epubBytes,
required bool fullData,
});
Future<EpubNovel> crateApiEpubParseEpubFromPath({
required String epubPath,
required bool fullData,
});
Uint8List crateApiImageProcessCropImage({required List<int> image});
Future<RequestClient> crateApiRhttpHttpRegisterClient({
required ClientSettings settings,
});
RequestClient crateApiRhttpHttpRegisterClientSync({
required ClientSettings settings,
});
RustArcIncrementStrongCountFnType
get rust_arc_increment_strong_count_CancellationToken;
RustArcDecrementStrongCountFnType
get rust_arc_decrement_strong_count_CancellationToken;
CrossPlatformFinalizerArg
get rust_arc_decrement_strong_count_CancellationTokenPtr;
RustArcIncrementStrongCountFnType
get rust_arc_increment_strong_count_DnsSettings;
RustArcDecrementStrongCountFnType
get rust_arc_decrement_strong_count_DnsSettings;
CrossPlatformFinalizerArg get rust_arc_decrement_strong_count_DnsSettingsPtr;
RustArcIncrementStrongCountFnType
get rust_arc_increment_strong_count_RequestClient;
RustArcDecrementStrongCountFnType
get rust_arc_decrement_strong_count_RequestClient;
CrossPlatformFinalizerArg
get rust_arc_decrement_strong_count_RequestClientPtr;
}
class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
RustLibApiImpl({
required super.handler,
required super.wire,
required super.generalizedFrbRustBinding,
required super.portManager,
});
@override
Future<void> crateApiRhttpHttpCancelRequest({
required CancellationToken token,
}) {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
token,
serializer,
);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 2,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_unit,
decodeErrorData: null,
),
constMeta: kCrateApiRhttpHttpCancelRequestConstMeta,
argValues: [token],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpHttpCancelRequestConstMeta =>
const TaskConstMeta(debugName: "cancel_request", argNames: ["token"]);
@override
Future<void> crateApiRhttpHttpCancelRunningRequests({
required RequestClient client,
}) {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
client,
serializer,
);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 3,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_unit,
decodeErrorData: null,
),
constMeta: kCrateApiRhttpHttpCancelRunningRequestsConstMeta,
argValues: [client],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpHttpCancelRunningRequestsConstMeta =>
const TaskConstMeta(
debugName: "cancel_running_requests",
argNames: ["client"],
);
@override
Future<ClientSettings> crateApiRhttpClientClientSettingsDefault() {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 4,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_client_settings,
decodeErrorData: null,
),
constMeta: kCrateApiRhttpClientClientSettingsDefaultConstMeta,
argValues: [],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpClientClientSettingsDefaultConstMeta =>
const TaskConstMeta(debugName: "client_settings_default", argNames: []);
@override
DnsSettings crateApiRhttpClientCreateDynamicResolverSync({
required FutureOr<List<String>> Function(String) resolver,
}) {
return handler.executeSync(
SyncTask(
callFfi: () {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_DartFn_Inputs_String_Output_list_String_AnyhowException(
resolver,
serializer,
);
return pdeCallFfi(generalizedFrbRustBinding, serializer, funcId: 5)!;
},
codec: SseCodec(
decodeSuccessData:
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings,
decodeErrorData: null,
),
constMeta: kCrateApiRhttpClientCreateDynamicResolverSyncConstMeta,
argValues: [resolver],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpClientCreateDynamicResolverSyncConstMeta =>
const TaskConstMeta(
debugName: "create_dynamic_resolver_sync",
argNames: ["resolver"],
);
@override
DnsSettings crateApiRhttpClientCreateStaticResolverSync({
required StaticDnsSettings settings,
}) {
return handler.executeSync(
SyncTask(
callFfi: () {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_box_autoadd_static_dns_settings(settings, serializer);
return pdeCallFfi(generalizedFrbRustBinding, serializer, funcId: 6)!;
},
codec: SseCodec(
decodeSuccessData:
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings,
decodeErrorData: null,
),
constMeta: kCrateApiRhttpClientCreateStaticResolverSyncConstMeta,
argValues: [settings],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpClientCreateStaticResolverSyncConstMeta =>
const TaskConstMeta(
debugName: "create_static_resolver_sync",
argNames: ["settings"],
);
@override
Future<String> crateApiEpubGetChapterContent({
required String epubPath,
required String chapterPath,
}) {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_String(epubPath, serializer);
sse_encode_String(chapterPath, serializer);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 7,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_String,
decodeErrorData: sse_decode_String,
),
constMeta: kCrateApiEpubGetChapterContentConstMeta,
argValues: [epubPath, chapterPath],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiEpubGetChapterContentConstMeta =>
const TaskConstMeta(
debugName: "get_chapter_content",
argNames: ["epubPath", "chapterPath"],
);
@override
Stream<Uint8List> crateApiRhttpHttpMakeHttpRequestReceiveStream({
RequestClient? client,
ClientSettings? settings,
required HttpMethod method,
required String url,
List<(String, String)>? query,
HttpHeaders? headers,
Uint8List? body,
required FutureOr<void> Function(HttpResponse) onResponse,
required FutureOr<void> Function(RhttpError) onError,
required FutureOr<void> Function(CancellationToken) onCancelToken,
required bool cancelable,
}) {
final streamSink = RustStreamSink<Uint8List>();
unawaited(
handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_opt_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
client,
serializer,
);
sse_encode_opt_box_autoadd_client_settings(settings, serializer);
sse_encode_http_method(method, serializer);
sse_encode_String(url, serializer);
sse_encode_opt_list_record_string_string(query, serializer);
sse_encode_opt_box_autoadd_http_headers(headers, serializer);
sse_encode_opt_list_prim_u_8_strict(body, serializer);
sse_encode_StreamSink_list_prim_u_8_strict_Sse(
streamSink,
serializer,
);
sse_encode_DartFn_Inputs_http_response_Output_unit_AnyhowException(
onResponse,
serializer,
);
sse_encode_DartFn_Inputs_rhttp_error_Output_unit_AnyhowException(
onError,
serializer,
);
sse_encode_DartFn_Inputs_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken_Output_unit_AnyhowException(
onCancelToken,
serializer,
);
sse_encode_bool(cancelable, serializer);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 8,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_unit,
decodeErrorData: sse_decode_rhttp_error,
),
constMeta: kCrateApiRhttpHttpMakeHttpRequestReceiveStreamConstMeta,
argValues: [
client,
settings,
method,
url,
query,
headers,
body,
streamSink,
onResponse,
onError,
onCancelToken,
cancelable,
],
apiImpl: this,
),
),
);
return streamSink.stream;
}
TaskConstMeta get kCrateApiRhttpHttpMakeHttpRequestReceiveStreamConstMeta =>
const TaskConstMeta(
debugName: "make_http_request_receive_stream",
argNames: [
"client",
"settings",
"method",
"url",
"query",
"headers",
"body",
"streamSink",
"onResponse",
"onError",
"onCancelToken",
"cancelable",
],
);
@override
Future<EpubNovel> crateApiEpubParseEpubFromBytes({
required List<int> epubBytes,
required bool fullData,
}) {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_list_prim_u_8_loose(epubBytes, serializer);
sse_encode_bool(fullData, serializer);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 9,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_epub_novel,
decodeErrorData: sse_decode_String,
),
constMeta: kCrateApiEpubParseEpubFromBytesConstMeta,
argValues: [epubBytes, fullData],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiEpubParseEpubFromBytesConstMeta =>
const TaskConstMeta(
debugName: "parse_epub_from_bytes",
argNames: ["epubBytes", "fullData"],
);
@override
Future<EpubNovel> crateApiEpubParseEpubFromPath({
required String epubPath,
required bool fullData,
}) {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_String(epubPath, serializer);
sse_encode_bool(fullData, serializer);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 10,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData: sse_decode_epub_novel,
decodeErrorData: sse_decode_String,
),
constMeta: kCrateApiEpubParseEpubFromPathConstMeta,
argValues: [epubPath, fullData],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiEpubParseEpubFromPathConstMeta =>
const TaskConstMeta(
debugName: "parse_epub_from_path",
argNames: ["epubPath", "fullData"],
);
@override
Uint8List crateApiImageProcessCropImage({required List<int> image}) {
return handler.executeSync(
SyncTask(
callFfi: () {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_list_prim_u_8_loose(image, serializer);
return pdeCallFfi(generalizedFrbRustBinding, serializer, funcId: 11)!;
},
codec: SseCodec(
decodeSuccessData: sse_decode_list_prim_u_8_strict,
decodeErrorData: null,
),
constMeta: kCrateApiImageProcessCropImageConstMeta,
argValues: [image],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiImageProcessCropImageConstMeta =>
const TaskConstMeta(debugName: "process_crop_image", argNames: ["image"]);
@override
Future<RequestClient> crateApiRhttpHttpRegisterClient({
required ClientSettings settings,
}) {
return handler.executeNormal(
NormalTask(
callFfi: (port_) {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_box_autoadd_client_settings(settings, serializer);
pdeCallFfi(
generalizedFrbRustBinding,
serializer,
funcId: 12,
port: port_,
);
},
codec: SseCodec(
decodeSuccessData:
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient,
decodeErrorData: sse_decode_rhttp_error,
),
constMeta: kCrateApiRhttpHttpRegisterClientConstMeta,
argValues: [settings],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpHttpRegisterClientConstMeta =>
const TaskConstMeta(debugName: "register_client", argNames: ["settings"]);
@override
RequestClient crateApiRhttpHttpRegisterClientSync({
required ClientSettings settings,
}) {
return handler.executeSync(
SyncTask(
callFfi: () {
final serializer = SseSerializer(generalizedFrbRustBinding);
sse_encode_box_autoadd_client_settings(settings, serializer);
return pdeCallFfi(generalizedFrbRustBinding, serializer, funcId: 13)!;
},
codec: SseCodec(
decodeSuccessData:
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient,
decodeErrorData: sse_decode_rhttp_error,
),
constMeta: kCrateApiRhttpHttpRegisterClientSyncConstMeta,
argValues: [settings],
apiImpl: this,
),
);
}
TaskConstMeta get kCrateApiRhttpHttpRegisterClientSyncConstMeta =>
const TaskConstMeta(
debugName: "register_client_sync",
argNames: ["settings"],
);
Future<void> Function(int, dynamic)
encode_DartFn_Inputs_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken_Output_unit_AnyhowException(
FutureOr<void> Function(CancellationToken) raw,
) {
return (callId, rawArg0) async {
final arg0 =
dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
rawArg0,
);
Box<void>? rawOutput;
Box<AnyhowException>? rawError;
try {
rawOutput = Box(await raw(arg0));
} catch (e, s) {
rawError = Box(AnyhowException("$e\n\n$s"));
}
final serializer = SseSerializer(generalizedFrbRustBinding);
assert((rawOutput != null) ^ (rawError != null));
if (rawOutput != null) {
serializer.buffer.putUint8(0);
sse_encode_unit(rawOutput.value, serializer);
} else {
serializer.buffer.putUint8(1);
sse_encode_AnyhowException(rawError!.value, serializer);
}
final output = serializer.intoRaw();
generalizedFrbRustBinding.dartFnDeliverOutput(
callId: callId,
ptr: output.ptr,
rustVecLen: output.rustVecLen,
dataLen: output.dataLen,
);
};
}
Future<void> Function(int, dynamic)
encode_DartFn_Inputs_String_Output_list_String_AnyhowException(
FutureOr<List<String>> Function(String) raw,
) {
return (callId, rawArg0) async {
final arg0 = dco_decode_String(rawArg0);
Box<List<String>>? rawOutput;
Box<AnyhowException>? rawError;
try {
rawOutput = Box(await raw(arg0));
} catch (e, s) {
rawError = Box(AnyhowException("$e\n\n$s"));
}
final serializer = SseSerializer(generalizedFrbRustBinding);
assert((rawOutput != null) ^ (rawError != null));
if (rawOutput != null) {
serializer.buffer.putUint8(0);
sse_encode_list_String(rawOutput.value, serializer);
} else {
serializer.buffer.putUint8(1);
sse_encode_AnyhowException(rawError!.value, serializer);
}
final output = serializer.intoRaw();
generalizedFrbRustBinding.dartFnDeliverOutput(
callId: callId,
ptr: output.ptr,
rustVecLen: output.rustVecLen,
dataLen: output.dataLen,
);
};
}
Future<void> Function(int, dynamic)
encode_DartFn_Inputs_http_response_Output_unit_AnyhowException(
FutureOr<void> Function(HttpResponse) raw,
) {
return (callId, rawArg0) async {
final arg0 = dco_decode_http_response(rawArg0);
Box<void>? rawOutput;
Box<AnyhowException>? rawError;
try {
rawOutput = Box(await raw(arg0));
} catch (e, s) {
rawError = Box(AnyhowException("$e\n\n$s"));
}
final serializer = SseSerializer(generalizedFrbRustBinding);
assert((rawOutput != null) ^ (rawError != null));
if (rawOutput != null) {
serializer.buffer.putUint8(0);
sse_encode_unit(rawOutput.value, serializer);
} else {
serializer.buffer.putUint8(1);
sse_encode_AnyhowException(rawError!.value, serializer);
}
final output = serializer.intoRaw();
generalizedFrbRustBinding.dartFnDeliverOutput(
callId: callId,
ptr: output.ptr,
rustVecLen: output.rustVecLen,
dataLen: output.dataLen,
);
};
}
Future<void> Function(int, dynamic)
encode_DartFn_Inputs_rhttp_error_Output_unit_AnyhowException(
FutureOr<void> Function(RhttpError) raw,
) {
return (callId, rawArg0) async {
final arg0 = dco_decode_rhttp_error(rawArg0);
Box<void>? rawOutput;
Box<AnyhowException>? rawError;
try {
rawOutput = Box(await raw(arg0));
} catch (e, s) {
rawError = Box(AnyhowException("$e\n\n$s"));
}
final serializer = SseSerializer(generalizedFrbRustBinding);
assert((rawOutput != null) ^ (rawError != null));
if (rawOutput != null) {
serializer.buffer.putUint8(0);
sse_encode_unit(rawOutput.value, serializer);
} else {
serializer.buffer.putUint8(1);
sse_encode_AnyhowException(rawError!.value, serializer);
}
final output = serializer.intoRaw();
generalizedFrbRustBinding.dartFnDeliverOutput(
callId: callId,
ptr: output.ptr,
rustVecLen: output.rustVecLen,
dataLen: output.dataLen,
);
};
}
RustArcIncrementStrongCountFnType
get rust_arc_increment_strong_count_CancellationToken => wire
.rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken;
RustArcDecrementStrongCountFnType
get rust_arc_decrement_strong_count_CancellationToken => wire
.rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken;
RustArcIncrementStrongCountFnType
get rust_arc_increment_strong_count_DnsSettings => wire
.rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings;
RustArcDecrementStrongCountFnType
get rust_arc_decrement_strong_count_DnsSettings => wire
.rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings;
RustArcIncrementStrongCountFnType
get rust_arc_increment_strong_count_RequestClient => wire
.rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient;
RustArcDecrementStrongCountFnType
get rust_arc_decrement_strong_count_RequestClient => wire
.rust_arc_decrement_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient;
@protected
AnyhowException dco_decode_AnyhowException(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return AnyhowException(raw as String);
}
@protected
RequestClient
dco_decode_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
raw,
);
}
@protected
CancellationToken
dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return CancellationTokenImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
DnsSettings
dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return DnsSettingsImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
RequestClient
dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return RequestClientImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
CancellationToken
dco_decode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return CancellationTokenImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
RequestClient
dco_decode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return RequestClientImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
Duration dco_decode_Chrono_Duration(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dcoDecodeDuration(dco_decode_i_64(raw).toInt());
}
@protected
FutureOr<void> Function(CancellationToken)
dco_decode_DartFn_Inputs_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken_Output_unit_AnyhowException(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
throw UnimplementedError('');
}
@protected
FutureOr<List<String>> Function(String)
dco_decode_DartFn_Inputs_String_Output_list_String_AnyhowException(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
throw UnimplementedError('');
}
@protected
FutureOr<void> Function(HttpResponse)
dco_decode_DartFn_Inputs_http_response_Output_unit_AnyhowException(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
throw UnimplementedError('');
}
@protected
FutureOr<void> Function(RhttpError)
dco_decode_DartFn_Inputs_rhttp_error_Output_unit_AnyhowException(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
throw UnimplementedError('');
}
@protected
Object dco_decode_DartOpaque(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return decodeDartOpaque(raw, generalizedFrbRustBinding);
}
@protected
Map<String, String> dco_decode_Map_String_String_None(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return Map.fromEntries(
dco_decode_list_record_string_string(
raw,
).map((e) => MapEntry(e.$1, e.$2)),
);
}
@protected
Map<String, List<String>> dco_decode_Map_String_list_String_None(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return Map.fromEntries(
dco_decode_list_record_string_list_string(
raw,
).map((e) => MapEntry(e.$1, e.$2)),
);
}
@protected
CancellationToken
dco_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return CancellationTokenImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
DnsSettings
dco_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return DnsSettingsImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
RequestClient
dco_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return RequestClientImpl.frbInternalDcoDecode(raw as List<dynamic>);
}
@protected
RustStreamSink<Uint8List> dco_decode_StreamSink_list_prim_u_8_strict_Sse(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
throw UnimplementedError();
}
@protected
String dco_decode_String(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as String;
}
@protected
SocketAddrDigester dco_decode_TraitDef_SocketAddrDigester(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
throw UnimplementedError();
}
@protected
bool dco_decode_bool(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as bool;
}
@protected
DnsSettings
dco_decode_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
raw,
);
}
@protected
Duration dco_decode_box_autoadd_Chrono_Duration(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_Chrono_Duration(raw);
}
@protected
ClientCertificate dco_decode_box_autoadd_client_certificate(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_client_certificate(raw);
}
@protected
ClientSettings dco_decode_box_autoadd_client_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_client_settings(raw);
}
@protected
HttpHeaders dco_decode_box_autoadd_http_headers(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_http_headers(raw);
}
@protected
HttpResponseBody dco_decode_box_autoadd_http_response_body(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_http_response_body(raw);
}
@protected
ProxySettings dco_decode_box_autoadd_proxy_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_proxy_settings(raw);
}
@protected
RedirectSettings dco_decode_box_autoadd_redirect_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_redirect_settings(raw);
}
@protected
StaticDnsSettings dco_decode_box_autoadd_static_dns_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_static_dns_settings(raw);
}
@protected
TimeoutSettings dco_decode_box_autoadd_timeout_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_timeout_settings(raw);
}
@protected
TlsSettings dco_decode_box_autoadd_tls_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_tls_settings(raw);
}
@protected
TlsVersion dco_decode_box_autoadd_tls_version(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dco_decode_tls_version(raw);
}
@protected
ClientCertificate dco_decode_client_certificate(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 2)
throw Exception('unexpected arr length: expect 2 but see ${arr.length}');
return ClientCertificate(
certificate: dco_decode_list_prim_u_8_strict(arr[0]),
privateKey: dco_decode_list_prim_u_8_strict(arr[1]),
);
}
@protected
ClientSettings dco_decode_client_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 6)
throw Exception('unexpected arr length: expect 6 but see ${arr.length}');
return ClientSettings(
timeoutSettings: dco_decode_opt_box_autoadd_timeout_settings(arr[0]),
throwOnStatusCode: dco_decode_bool(arr[1]),
proxySettings: dco_decode_opt_box_autoadd_proxy_settings(arr[2]),
redirectSettings: dco_decode_opt_box_autoadd_redirect_settings(arr[3]),
tlsSettings: dco_decode_opt_box_autoadd_tls_settings(arr[4]),
dnsSettings:
dco_decode_opt_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
arr[5],
),
);
}
@protected
CustomProxy dco_decode_custom_proxy(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 2)
throw Exception('unexpected arr length: expect 2 but see ${arr.length}');
return CustomProxy(
url: dco_decode_String(arr[0]),
condition: dco_decode_proxy_condition(arr[1]),
);
}
@protected
EpubChapter dco_decode_epub_chapter(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 3)
throw Exception('unexpected arr length: expect 3 but see ${arr.length}');
return EpubChapter(
name: dco_decode_String(arr[0]),
content: dco_decode_String(arr[1]),
path: dco_decode_String(arr[2]),
);
}
@protected
EpubNovel dco_decode_epub_novel(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 8)
throw Exception('unexpected arr length: expect 8 but see ${arr.length}');
return EpubNovel(
name: dco_decode_String(arr[0]),
cover: dco_decode_opt_list_prim_u_8_strict(arr[1]),
summary: dco_decode_opt_String(arr[2]),
author: dco_decode_opt_String(arr[3]),
artist: dco_decode_opt_String(arr[4]),
chapters: dco_decode_list_epub_chapter(arr[5]),
images: dco_decode_list_epub_resource(arr[6]),
stylesheets: dco_decode_list_epub_resource(arr[7]),
);
}
@protected
EpubResource dco_decode_epub_resource(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 2)
throw Exception('unexpected arr length: expect 2 but see ${arr.length}');
return EpubResource(
name: dco_decode_String(arr[0]),
content: dco_decode_list_prim_u_8_strict(arr[1]),
);
}
@protected
HttpHeaders dco_decode_http_headers(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
switch (raw[0]) {
case 0:
return HttpHeaders_Map(dco_decode_Map_String_String_None(raw[1]));
case 1:
return HttpHeaders_List(dco_decode_list_record_string_string(raw[1]));
default:
throw Exception("unreachable");
}
}
@protected
HttpMethod dco_decode_http_method(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return HttpMethod.values[raw as int];
}
@protected
HttpResponse dco_decode_http_response(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 4)
throw Exception('unexpected arr length: expect 4 but see ${arr.length}');
return HttpResponse(
headers: dco_decode_list_record_string_string(arr[0]),
version: dco_decode_http_version(arr[1]),
statusCode: dco_decode_u_16(arr[2]),
body: dco_decode_http_response_body(arr[3]),
);
}
@protected
HttpResponseBody dco_decode_http_response_body(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
switch (raw[0]) {
case 0:
return HttpResponseBody_Text(dco_decode_String(raw[1]));
case 1:
return HttpResponseBody_Bytes(dco_decode_list_prim_u_8_strict(raw[1]));
case 2:
return HttpResponseBody_Stream();
default:
throw Exception("unreachable");
}
}
@protected
HttpVersion dco_decode_http_version(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return HttpVersion.values[raw as int];
}
@protected
int dco_decode_i_32(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as int;
}
@protected
PlatformInt64 dco_decode_i_64(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dcoDecodeI64(raw);
}
@protected
PlatformInt64 dco_decode_isize(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dcoDecodeI64(raw);
}
@protected
List<String> dco_decode_list_String(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>).map(dco_decode_String).toList();
}
@protected
List<CustomProxy> dco_decode_list_custom_proxy(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>).map(dco_decode_custom_proxy).toList();
}
@protected
List<EpubChapter> dco_decode_list_epub_chapter(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>).map(dco_decode_epub_chapter).toList();
}
@protected
List<EpubResource> dco_decode_list_epub_resource(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>).map(dco_decode_epub_resource).toList();
}
@protected
List<Uint8List> dco_decode_list_list_prim_u_8_strict(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>).map(dco_decode_list_prim_u_8_strict).toList();
}
@protected
List<int> dco_decode_list_prim_u_8_loose(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as List<int>;
}
@protected
Uint8List dco_decode_list_prim_u_8_strict(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as Uint8List;
}
@protected
List<(String, List<String>)> dco_decode_list_record_string_list_string(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>)
.map(dco_decode_record_string_list_string)
.toList();
}
@protected
List<(String, String)> dco_decode_list_record_string_string(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return (raw as List<dynamic>).map(dco_decode_record_string_string).toList();
}
@protected
RequestClient?
dco_decode_opt_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null
? null
: dco_decode_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
raw,
);
}
@protected
String? dco_decode_opt_String(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_String(raw);
}
@protected
DnsSettings?
dco_decode_opt_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null
? null
: dco_decode_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
raw,
);
}
@protected
Duration? dco_decode_opt_box_autoadd_Chrono_Duration(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_Chrono_Duration(raw);
}
@protected
ClientCertificate? dco_decode_opt_box_autoadd_client_certificate(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_client_certificate(raw);
}
@protected
ClientSettings? dco_decode_opt_box_autoadd_client_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_client_settings(raw);
}
@protected
HttpHeaders? dco_decode_opt_box_autoadd_http_headers(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_http_headers(raw);
}
@protected
ProxySettings? dco_decode_opt_box_autoadd_proxy_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_proxy_settings(raw);
}
@protected
RedirectSettings? dco_decode_opt_box_autoadd_redirect_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_redirect_settings(raw);
}
@protected
TimeoutSettings? dco_decode_opt_box_autoadd_timeout_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_timeout_settings(raw);
}
@protected
TlsSettings? dco_decode_opt_box_autoadd_tls_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_tls_settings(raw);
}
@protected
TlsVersion? dco_decode_opt_box_autoadd_tls_version(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_box_autoadd_tls_version(raw);
}
@protected
Uint8List? dco_decode_opt_list_prim_u_8_strict(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_list_prim_u_8_strict(raw);
}
@protected
List<(String, String)>? dco_decode_opt_list_record_string_string(
dynamic raw,
) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw == null ? null : dco_decode_list_record_string_string(raw);
}
@protected
ProxyCondition dco_decode_proxy_condition(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return ProxyCondition.values[raw as int];
}
@protected
ProxySettings dco_decode_proxy_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
switch (raw[0]) {
case 0:
return ProxySettings_NoProxy();
case 1:
return ProxySettings_CustomProxyList(
dco_decode_list_custom_proxy(raw[1]),
);
default:
throw Exception("unreachable");
}
}
@protected
(String, List<String>) dco_decode_record_string_list_string(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 2) {
throw Exception('Expected 2 elements, got ${arr.length}');
}
return (dco_decode_String(arr[0]), dco_decode_list_String(arr[1]));
}
@protected
(String, String) dco_decode_record_string_string(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 2) {
throw Exception('Expected 2 elements, got ${arr.length}');
}
return (dco_decode_String(arr[0]), dco_decode_String(arr[1]));
}
@protected
RedirectSettings dco_decode_redirect_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
switch (raw[0]) {
case 0:
return RedirectSettings_NoRedirect();
case 1:
return RedirectSettings_LimitedRedirects(dco_decode_i_32(raw[1]));
default:
throw Exception("unreachable");
}
}
@protected
RhttpError dco_decode_rhttp_error(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
switch (raw[0]) {
case 0:
return RhttpError_RhttpCancelError();
case 1:
return RhttpError_RhttpTimeoutError();
case 2:
return RhttpError_RhttpRedirectError();
case 3:
return RhttpError_RhttpStatusCodeError(
dco_decode_u_16(raw[1]),
dco_decode_list_record_string_string(raw[2]),
dco_decode_box_autoadd_http_response_body(raw[3]),
);
case 4:
return RhttpError_RhttpInvalidCertificateError(
dco_decode_String(raw[1]),
);
case 5:
return RhttpError_RhttpConnectionError(dco_decode_String(raw[1]));
case 6:
return RhttpError_RhttpUnknownError(dco_decode_String(raw[1]));
default:
throw Exception("unreachable");
}
}
@protected
StaticDnsSettings dco_decode_static_dns_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 2)
throw Exception('unexpected arr length: expect 2 but see ${arr.length}');
return StaticDnsSettings(
overrides: dco_decode_Map_String_list_String_None(arr[0]),
fallback: dco_decode_opt_String(arr[1]),
);
}
@protected
TimeoutSettings dco_decode_timeout_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 4)
throw Exception('unexpected arr length: expect 4 but see ${arr.length}');
return TimeoutSettings(
timeout: dco_decode_opt_box_autoadd_Chrono_Duration(arr[0]),
connectTimeout: dco_decode_opt_box_autoadd_Chrono_Duration(arr[1]),
keepAliveTimeout: dco_decode_opt_box_autoadd_Chrono_Duration(arr[2]),
keepAlivePing: dco_decode_opt_box_autoadd_Chrono_Duration(arr[3]),
);
}
@protected
TlsSettings dco_decode_tls_settings(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
final arr = raw as List<dynamic>;
if (arr.length != 6)
throw Exception('unexpected arr length: expect 6 but see ${arr.length}');
return TlsSettings(
trustRootCertificates: dco_decode_bool(arr[0]),
trustedRootCertificates: dco_decode_list_list_prim_u_8_strict(arr[1]),
verifyCertificates: dco_decode_bool(arr[2]),
clientCertificate: dco_decode_opt_box_autoadd_client_certificate(arr[3]),
minTlsVersion: dco_decode_opt_box_autoadd_tls_version(arr[4]),
maxTlsVersion: dco_decode_opt_box_autoadd_tls_version(arr[5]),
);
}
@protected
TlsVersion dco_decode_tls_version(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return TlsVersion.values[raw as int];
}
@protected
int dco_decode_u_16(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as int;
}
@protected
int dco_decode_u_8(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return raw as int;
}
@protected
void dco_decode_unit(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return;
}
@protected
BigInt dco_decode_usize(dynamic raw) {
// Codec=Dco (DartCObject based), see doc to use other codecs
return dcoDecodeU64(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
RequestClient
sse_decode_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner =
sse_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
deserializer,
);
return inner;
}
@protected
CancellationToken
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return CancellationTokenImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
DnsSettings
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return DnsSettingsImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
RequestClient
sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return RequestClientImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
CancellationToken
sse_decode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return CancellationTokenImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
RequestClient
sse_decode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return RequestClientImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
Duration sse_decode_Chrono_Duration(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_i_64(deserializer);
return Duration(microseconds: inner.toInt());
}
@protected
Object sse_decode_DartOpaque(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_isize(deserializer);
return decodeDartOpaque(inner, generalizedFrbRustBinding);
}
@protected
Map<String, String> sse_decode_Map_String_String_None(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_list_record_string_string(deserializer);
return Map.fromEntries(inner.map((e) => MapEntry(e.$1, e.$2)));
}
@protected
Map<String, List<String>> sse_decode_Map_String_list_String_None(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_list_record_string_list_string(deserializer);
return Map.fromEntries(inner.map((e) => MapEntry(e.$1, e.$2)));
}
@protected
CancellationToken
sse_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return CancellationTokenImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
DnsSettings
sse_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return DnsSettingsImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
RequestClient
sse_decode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return RequestClientImpl.frbInternalSseDecode(
sse_decode_usize(deserializer),
sse_decode_i_32(deserializer),
);
}
@protected
RustStreamSink<Uint8List> sse_decode_StreamSink_list_prim_u_8_strict_Sse(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
throw UnimplementedError('Unreachable ()');
}
@protected
String sse_decode_String(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_list_prim_u_8_strict(deserializer);
return utf8.decoder.convert(inner);
}
@protected
bool sse_decode_bool(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getUint8() != 0;
}
@protected
DnsSettings
sse_decode_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
deserializer,
));
}
@protected
Duration sse_decode_box_autoadd_Chrono_Duration(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_Chrono_Duration(deserializer));
}
@protected
ClientCertificate sse_decode_box_autoadd_client_certificate(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_client_certificate(deserializer));
}
@protected
ClientSettings sse_decode_box_autoadd_client_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_client_settings(deserializer));
}
@protected
HttpHeaders sse_decode_box_autoadd_http_headers(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_http_headers(deserializer));
}
@protected
HttpResponseBody sse_decode_box_autoadd_http_response_body(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_http_response_body(deserializer));
}
@protected
ProxySettings sse_decode_box_autoadd_proxy_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_proxy_settings(deserializer));
}
@protected
RedirectSettings sse_decode_box_autoadd_redirect_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_redirect_settings(deserializer));
}
@protected
StaticDnsSettings sse_decode_box_autoadd_static_dns_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_static_dns_settings(deserializer));
}
@protected
TimeoutSettings sse_decode_box_autoadd_timeout_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_timeout_settings(deserializer));
}
@protected
TlsSettings sse_decode_box_autoadd_tls_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_tls_settings(deserializer));
}
@protected
TlsVersion sse_decode_box_autoadd_tls_version(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return (sse_decode_tls_version(deserializer));
}
@protected
ClientCertificate sse_decode_client_certificate(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_certificate = sse_decode_list_prim_u_8_strict(deserializer);
var var_privateKey = sse_decode_list_prim_u_8_strict(deserializer);
return ClientCertificate(
certificate: var_certificate,
privateKey: var_privateKey,
);
}
@protected
ClientSettings sse_decode_client_settings(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_timeoutSettings = sse_decode_opt_box_autoadd_timeout_settings(
deserializer,
);
var var_throwOnStatusCode = sse_decode_bool(deserializer);
var var_proxySettings = sse_decode_opt_box_autoadd_proxy_settings(
deserializer,
);
var var_redirectSettings = sse_decode_opt_box_autoadd_redirect_settings(
deserializer,
);
var var_tlsSettings = sse_decode_opt_box_autoadd_tls_settings(deserializer);
var var_dnsSettings =
sse_decode_opt_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
deserializer,
);
return ClientSettings(
timeoutSettings: var_timeoutSettings,
throwOnStatusCode: var_throwOnStatusCode,
proxySettings: var_proxySettings,
redirectSettings: var_redirectSettings,
tlsSettings: var_tlsSettings,
dnsSettings: var_dnsSettings,
);
}
@protected
CustomProxy sse_decode_custom_proxy(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_url = sse_decode_String(deserializer);
var var_condition = sse_decode_proxy_condition(deserializer);
return CustomProxy(url: var_url, condition: var_condition);
}
@protected
EpubChapter sse_decode_epub_chapter(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_name = sse_decode_String(deserializer);
var var_content = sse_decode_String(deserializer);
var var_path = sse_decode_String(deserializer);
return EpubChapter(name: var_name, content: var_content, path: var_path);
}
@protected
EpubNovel sse_decode_epub_novel(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_name = sse_decode_String(deserializer);
var var_cover = sse_decode_opt_list_prim_u_8_strict(deserializer);
var var_summary = sse_decode_opt_String(deserializer);
var var_author = sse_decode_opt_String(deserializer);
var var_artist = sse_decode_opt_String(deserializer);
var var_chapters = sse_decode_list_epub_chapter(deserializer);
var var_images = sse_decode_list_epub_resource(deserializer);
var var_stylesheets = sse_decode_list_epub_resource(deserializer);
return EpubNovel(
name: var_name,
cover: var_cover,
summary: var_summary,
author: var_author,
artist: var_artist,
chapters: var_chapters,
images: var_images,
stylesheets: var_stylesheets,
);
}
@protected
EpubResource sse_decode_epub_resource(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_name = sse_decode_String(deserializer);
var var_content = sse_decode_list_prim_u_8_strict(deserializer);
return EpubResource(name: var_name, content: var_content);
}
@protected
HttpHeaders sse_decode_http_headers(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_Map_String_String_None(deserializer);
return HttpHeaders_Map(var_field0);
case 1:
var var_field0 = sse_decode_list_record_string_string(deserializer);
return HttpHeaders_List(var_field0);
default:
throw UnimplementedError('');
}
}
@protected
HttpMethod sse_decode_http_method(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_i_32(deserializer);
return HttpMethod.values[inner];
}
@protected
HttpResponse sse_decode_http_response(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_headers = sse_decode_list_record_string_string(deserializer);
var var_version = sse_decode_http_version(deserializer);
var var_statusCode = sse_decode_u_16(deserializer);
var var_body = sse_decode_http_response_body(deserializer);
return HttpResponse(
headers: var_headers,
version: var_version,
statusCode: var_statusCode,
body: var_body,
);
}
@protected
HttpResponseBody sse_decode_http_response_body(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 HttpResponseBody_Text(var_field0);
case 1:
var var_field0 = sse_decode_list_prim_u_8_strict(deserializer);
return HttpResponseBody_Bytes(var_field0);
case 2:
return HttpResponseBody_Stream();
default:
throw UnimplementedError('');
}
}
@protected
HttpVersion sse_decode_http_version(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_i_32(deserializer);
return HttpVersion.values[inner];
}
@protected
int sse_decode_i_32(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getInt32();
}
@protected
PlatformInt64 sse_decode_i_64(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getPlatformInt64();
}
@protected
PlatformInt64 sse_decode_isize(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getPlatformInt64();
}
@protected
List<String> sse_decode_list_String(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <String>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_String(deserializer));
}
return ans_;
}
@protected
List<CustomProxy> sse_decode_list_custom_proxy(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <CustomProxy>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_custom_proxy(deserializer));
}
return ans_;
}
@protected
List<EpubChapter> sse_decode_list_epub_chapter(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <EpubChapter>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_epub_chapter(deserializer));
}
return ans_;
}
@protected
List<EpubResource> sse_decode_list_epub_resource(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <EpubResource>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_epub_resource(deserializer));
}
return ans_;
}
@protected
List<Uint8List> sse_decode_list_list_prim_u_8_strict(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <Uint8List>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_list_prim_u_8_strict(deserializer));
}
return ans_;
}
@protected
List<int> sse_decode_list_prim_u_8_loose(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
return deserializer.buffer.getUint8List(len_);
}
@protected
Uint8List sse_decode_list_prim_u_8_strict(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
return deserializer.buffer.getUint8List(len_);
}
@protected
List<(String, List<String>)> sse_decode_list_record_string_list_string(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <(String, List<String>)>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_record_string_list_string(deserializer));
}
return ans_;
}
@protected
List<(String, String)> sse_decode_list_record_string_string(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var len_ = sse_decode_i_32(deserializer);
var ans_ = <(String, String)>[];
for (var idx_ = 0; idx_ < len_; ++idx_) {
ans_.add(sse_decode_record_string_string(deserializer));
}
return ans_;
}
@protected
RequestClient?
sse_decode_opt_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
deserializer,
));
} else {
return null;
}
}
@protected
String? sse_decode_opt_String(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_String(deserializer));
} else {
return null;
}
}
@protected
DnsSettings?
sse_decode_opt_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
deserializer,
));
} else {
return null;
}
}
@protected
Duration? sse_decode_opt_box_autoadd_Chrono_Duration(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_Chrono_Duration(deserializer));
} else {
return null;
}
}
@protected
ClientCertificate? sse_decode_opt_box_autoadd_client_certificate(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_client_certificate(deserializer));
} else {
return null;
}
}
@protected
ClientSettings? sse_decode_opt_box_autoadd_client_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_client_settings(deserializer));
} else {
return null;
}
}
@protected
HttpHeaders? sse_decode_opt_box_autoadd_http_headers(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_http_headers(deserializer));
} else {
return null;
}
}
@protected
ProxySettings? sse_decode_opt_box_autoadd_proxy_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_proxy_settings(deserializer));
} else {
return null;
}
}
@protected
RedirectSettings? sse_decode_opt_box_autoadd_redirect_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_redirect_settings(deserializer));
} else {
return null;
}
}
@protected
TimeoutSettings? sse_decode_opt_box_autoadd_timeout_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_timeout_settings(deserializer));
} else {
return null;
}
}
@protected
TlsSettings? sse_decode_opt_box_autoadd_tls_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_tls_settings(deserializer));
} else {
return null;
}
}
@protected
TlsVersion? sse_decode_opt_box_autoadd_tls_version(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_box_autoadd_tls_version(deserializer));
} else {
return null;
}
}
@protected
Uint8List? sse_decode_opt_list_prim_u_8_strict(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_list_prim_u_8_strict(deserializer));
} else {
return null;
}
}
@protected
List<(String, String)>? sse_decode_opt_list_record_string_string(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
if (sse_decode_bool(deserializer)) {
return (sse_decode_list_record_string_string(deserializer));
} else {
return null;
}
}
@protected
ProxyCondition sse_decode_proxy_condition(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_i_32(deserializer);
return ProxyCondition.values[inner];
}
@protected
ProxySettings sse_decode_proxy_settings(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var tag_ = sse_decode_i_32(deserializer);
switch (tag_) {
case 0:
return ProxySettings_NoProxy();
case 1:
var var_field0 = sse_decode_list_custom_proxy(deserializer);
return ProxySettings_CustomProxyList(var_field0);
default:
throw UnimplementedError('');
}
}
@protected
(String, List<String>) sse_decode_record_string_list_string(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_field0 = sse_decode_String(deserializer);
var var_field1 = sse_decode_list_String(deserializer);
return (var_field0, var_field1);
}
@protected
(String, String) sse_decode_record_string_string(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_field0 = sse_decode_String(deserializer);
var var_field1 = sse_decode_String(deserializer);
return (var_field0, var_field1);
}
@protected
RedirectSettings sse_decode_redirect_settings(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var tag_ = sse_decode_i_32(deserializer);
switch (tag_) {
case 0:
return RedirectSettings_NoRedirect();
case 1:
var var_field0 = sse_decode_i_32(deserializer);
return RedirectSettings_LimitedRedirects(var_field0);
default:
throw UnimplementedError('');
}
}
@protected
RhttpError sse_decode_rhttp_error(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var tag_ = sse_decode_i_32(deserializer);
switch (tag_) {
case 0:
return RhttpError_RhttpCancelError();
case 1:
return RhttpError_RhttpTimeoutError();
case 2:
return RhttpError_RhttpRedirectError();
case 3:
var var_field0 = sse_decode_u_16(deserializer);
var var_field1 = sse_decode_list_record_string_string(deserializer);
var var_field2 = sse_decode_box_autoadd_http_response_body(
deserializer,
);
return RhttpError_RhttpStatusCodeError(
var_field0,
var_field1,
var_field2,
);
case 4:
var var_field0 = sse_decode_String(deserializer);
return RhttpError_RhttpInvalidCertificateError(var_field0);
case 5:
var var_field0 = sse_decode_String(deserializer);
return RhttpError_RhttpConnectionError(var_field0);
case 6:
var var_field0 = sse_decode_String(deserializer);
return RhttpError_RhttpUnknownError(var_field0);
default:
throw UnimplementedError('');
}
}
@protected
StaticDnsSettings sse_decode_static_dns_settings(
SseDeserializer deserializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_overrides = sse_decode_Map_String_list_String_None(deserializer);
var var_fallback = sse_decode_opt_String(deserializer);
return StaticDnsSettings(overrides: var_overrides, fallback: var_fallback);
}
@protected
TimeoutSettings sse_decode_timeout_settings(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_timeout = sse_decode_opt_box_autoadd_Chrono_Duration(deserializer);
var var_connectTimeout = sse_decode_opt_box_autoadd_Chrono_Duration(
deserializer,
);
var var_keepAliveTimeout = sse_decode_opt_box_autoadd_Chrono_Duration(
deserializer,
);
var var_keepAlivePing = sse_decode_opt_box_autoadd_Chrono_Duration(
deserializer,
);
return TimeoutSettings(
timeout: var_timeout,
connectTimeout: var_connectTimeout,
keepAliveTimeout: var_keepAliveTimeout,
keepAlivePing: var_keepAlivePing,
);
}
@protected
TlsSettings sse_decode_tls_settings(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var var_trustRootCertificates = sse_decode_bool(deserializer);
var var_trustedRootCertificates = sse_decode_list_list_prim_u_8_strict(
deserializer,
);
var var_verifyCertificates = sse_decode_bool(deserializer);
var var_clientCertificate = sse_decode_opt_box_autoadd_client_certificate(
deserializer,
);
var var_minTlsVersion = sse_decode_opt_box_autoadd_tls_version(
deserializer,
);
var var_maxTlsVersion = sse_decode_opt_box_autoadd_tls_version(
deserializer,
);
return TlsSettings(
trustRootCertificates: var_trustRootCertificates,
trustedRootCertificates: var_trustedRootCertificates,
verifyCertificates: var_verifyCertificates,
clientCertificate: var_clientCertificate,
minTlsVersion: var_minTlsVersion,
maxTlsVersion: var_maxTlsVersion,
);
}
@protected
TlsVersion sse_decode_tls_version(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
var inner = sse_decode_i_32(deserializer);
return TlsVersion.values[inner];
}
@protected
int sse_decode_u_16(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getUint16();
}
@protected
int sse_decode_u_8(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getUint8();
}
@protected
void sse_decode_unit(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
}
@protected
BigInt sse_decode_usize(SseDeserializer deserializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
return deserializer.buffer.getBigUint64();
}
@protected
void sse_encode_AnyhowException(
AnyhowException self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.message, serializer);
}
@protected
void
sse_encode_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
RequestClient self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
self,
serializer,
);
}
@protected
void
sse_encode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
CancellationToken self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as CancellationTokenImpl).frbInternalSseEncode(move: true),
serializer,
);
}
@protected
void
sse_encode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
DnsSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as DnsSettingsImpl).frbInternalSseEncode(move: true),
serializer,
);
}
@protected
void
sse_encode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
RequestClient self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as RequestClientImpl).frbInternalSseEncode(move: true),
serializer,
);
}
@protected
void
sse_encode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
CancellationToken self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as CancellationTokenImpl).frbInternalSseEncode(move: false),
serializer,
);
}
@protected
void
sse_encode_Auto_Ref_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
RequestClient self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as RequestClientImpl).frbInternalSseEncode(move: false),
serializer,
);
}
@protected
void sse_encode_Chrono_Duration(Duration self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_64(PlatformInt64Util.from(self.inMicroseconds), serializer);
}
@protected
void
sse_encode_DartFn_Inputs_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken_Output_unit_AnyhowException(
FutureOr<void> Function(CancellationToken) self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_DartOpaque(
encode_DartFn_Inputs_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken_Output_unit_AnyhowException(
self,
),
serializer,
);
}
@protected
void sse_encode_DartFn_Inputs_String_Output_list_String_AnyhowException(
FutureOr<List<String>> Function(String) self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_DartOpaque(
encode_DartFn_Inputs_String_Output_list_String_AnyhowException(self),
serializer,
);
}
@protected
void sse_encode_DartFn_Inputs_http_response_Output_unit_AnyhowException(
FutureOr<void> Function(HttpResponse) self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_DartOpaque(
encode_DartFn_Inputs_http_response_Output_unit_AnyhowException(self),
serializer,
);
}
@protected
void sse_encode_DartFn_Inputs_rhttp_error_Output_unit_AnyhowException(
FutureOr<void> Function(RhttpError) self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_DartOpaque(
encode_DartFn_Inputs_rhttp_error_Output_unit_AnyhowException(self),
serializer,
);
}
@protected
void sse_encode_DartOpaque(Object self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_isize(
PlatformPointerUtil.ptrToPlatformInt64(
encodeDartOpaque(
self,
portManager.dartHandlerPort,
generalizedFrbRustBinding,
),
),
serializer,
);
}
@protected
void sse_encode_Map_String_String_None(
Map<String, String> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_list_record_string_string(
self.entries.map((e) => (e.key, e.value)).toList(),
serializer,
);
}
@protected
void sse_encode_Map_String_list_String_None(
Map<String, List<String>> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_list_record_string_list_string(
self.entries.map((e) => (e.key, e.value)).toList(),
serializer,
);
}
@protected
void
sse_encode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerCancellationToken(
CancellationToken self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as CancellationTokenImpl).frbInternalSseEncode(move: null),
serializer,
);
}
@protected
void
sse_encode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
DnsSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as DnsSettingsImpl).frbInternalSseEncode(move: null),
serializer,
);
}
@protected
void
sse_encode_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
RequestClient self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_usize(
(self as RequestClientImpl).frbInternalSseEncode(move: null),
serializer,
);
}
@protected
void sse_encode_StreamSink_list_prim_u_8_strict_Sse(
RustStreamSink<Uint8List> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(
self.setupAndSerialize(
codec: SseCodec(
decodeSuccessData: sse_decode_list_prim_u_8_strict,
decodeErrorData: sse_decode_AnyhowException,
),
),
serializer,
);
}
@protected
void sse_encode_String(String self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_list_prim_u_8_strict(utf8.encoder.convert(self), serializer);
}
@protected
void sse_encode_bool(bool self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putUint8(self ? 1 : 0);
}
@protected
void
sse_encode_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
DnsSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
self,
serializer,
);
}
@protected
void sse_encode_box_autoadd_Chrono_Duration(
Duration self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_Chrono_Duration(self, serializer);
}
@protected
void sse_encode_box_autoadd_client_certificate(
ClientCertificate self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_client_certificate(self, serializer);
}
@protected
void sse_encode_box_autoadd_client_settings(
ClientSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_client_settings(self, serializer);
}
@protected
void sse_encode_box_autoadd_http_headers(
HttpHeaders self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_http_headers(self, serializer);
}
@protected
void sse_encode_box_autoadd_http_response_body(
HttpResponseBody self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_http_response_body(self, serializer);
}
@protected
void sse_encode_box_autoadd_proxy_settings(
ProxySettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_proxy_settings(self, serializer);
}
@protected
void sse_encode_box_autoadd_redirect_settings(
RedirectSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_redirect_settings(self, serializer);
}
@protected
void sse_encode_box_autoadd_static_dns_settings(
StaticDnsSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_static_dns_settings(self, serializer);
}
@protected
void sse_encode_box_autoadd_timeout_settings(
TimeoutSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_timeout_settings(self, serializer);
}
@protected
void sse_encode_box_autoadd_tls_settings(
TlsSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_tls_settings(self, serializer);
}
@protected
void sse_encode_box_autoadd_tls_version(
TlsVersion self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_tls_version(self, serializer);
}
@protected
void sse_encode_client_certificate(
ClientCertificate self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_list_prim_u_8_strict(self.certificate, serializer);
sse_encode_list_prim_u_8_strict(self.privateKey, serializer);
}
@protected
void sse_encode_client_settings(
ClientSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_opt_box_autoadd_timeout_settings(
self.timeoutSettings,
serializer,
);
sse_encode_bool(self.throwOnStatusCode, serializer);
sse_encode_opt_box_autoadd_proxy_settings(self.proxySettings, serializer);
sse_encode_opt_box_autoadd_redirect_settings(
self.redirectSettings,
serializer,
);
sse_encode_opt_box_autoadd_tls_settings(self.tlsSettings, serializer);
sse_encode_opt_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
self.dnsSettings,
serializer,
);
}
@protected
void sse_encode_custom_proxy(CustomProxy self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.url, serializer);
sse_encode_proxy_condition(self.condition, serializer);
}
@protected
void sse_encode_epub_chapter(EpubChapter self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.name, serializer);
sse_encode_String(self.content, serializer);
sse_encode_String(self.path, serializer);
}
@protected
void sse_encode_epub_novel(EpubNovel self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.name, serializer);
sse_encode_opt_list_prim_u_8_strict(self.cover, serializer);
sse_encode_opt_String(self.summary, serializer);
sse_encode_opt_String(self.author, serializer);
sse_encode_opt_String(self.artist, serializer);
sse_encode_list_epub_chapter(self.chapters, serializer);
sse_encode_list_epub_resource(self.images, serializer);
sse_encode_list_epub_resource(self.stylesheets, serializer);
}
@protected
void sse_encode_epub_resource(EpubResource self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.name, serializer);
sse_encode_list_prim_u_8_strict(self.content, serializer);
}
@protected
void sse_encode_http_headers(HttpHeaders self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
switch (self) {
case HttpHeaders_Map(field0: final field0):
sse_encode_i_32(0, serializer);
sse_encode_Map_String_String_None(field0, serializer);
case HttpHeaders_List(field0: final field0):
sse_encode_i_32(1, serializer);
sse_encode_list_record_string_string(field0, serializer);
}
}
@protected
void sse_encode_http_method(HttpMethod self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.index, serializer);
}
@protected
void sse_encode_http_response(HttpResponse self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_list_record_string_string(self.headers, serializer);
sse_encode_http_version(self.version, serializer);
sse_encode_u_16(self.statusCode, serializer);
sse_encode_http_response_body(self.body, serializer);
}
@protected
void sse_encode_http_response_body(
HttpResponseBody self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
switch (self) {
case HttpResponseBody_Text(field0: final field0):
sse_encode_i_32(0, serializer);
sse_encode_String(field0, serializer);
case HttpResponseBody_Bytes(field0: final field0):
sse_encode_i_32(1, serializer);
sse_encode_list_prim_u_8_strict(field0, serializer);
case HttpResponseBody_Stream():
sse_encode_i_32(2, serializer);
}
}
@protected
void sse_encode_http_version(HttpVersion self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.index, serializer);
}
@protected
void sse_encode_i_32(int self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putInt32(self);
}
@protected
void sse_encode_i_64(PlatformInt64 self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putPlatformInt64(self);
}
@protected
void sse_encode_isize(PlatformInt64 self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putPlatformInt64(self);
}
@protected
void sse_encode_list_String(List<String> self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_String(item, serializer);
}
}
@protected
void sse_encode_list_custom_proxy(
List<CustomProxy> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_custom_proxy(item, serializer);
}
}
@protected
void sse_encode_list_epub_chapter(
List<EpubChapter> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_epub_chapter(item, serializer);
}
}
@protected
void sse_encode_list_epub_resource(
List<EpubResource> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_epub_resource(item, serializer);
}
}
@protected
void sse_encode_list_list_prim_u_8_strict(
List<Uint8List> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_list_prim_u_8_strict(item, serializer);
}
}
@protected
void sse_encode_list_prim_u_8_loose(
List<int> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
serializer.buffer.putUint8List(
self is Uint8List ? self : Uint8List.fromList(self),
);
}
@protected
void sse_encode_list_prim_u_8_strict(
Uint8List self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
serializer.buffer.putUint8List(self);
}
@protected
void sse_encode_list_record_string_list_string(
List<(String, List<String>)> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_record_string_list_string(item, serializer);
}
}
@protected
void sse_encode_list_record_string_string(
List<(String, String)> self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.length, serializer);
for (final item in self) {
sse_encode_record_string_string(item, serializer);
}
}
@protected
void
sse_encode_opt_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
RequestClient? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_AutoExplicit_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRequestClient(
self,
serializer,
);
}
}
@protected
void sse_encode_opt_String(String? self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_String(self, serializer);
}
}
@protected
void
sse_encode_opt_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
DnsSettings? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerDnsSettings(
self,
serializer,
);
}
}
@protected
void sse_encode_opt_box_autoadd_Chrono_Duration(
Duration? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_Chrono_Duration(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_client_certificate(
ClientCertificate? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_client_certificate(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_client_settings(
ClientSettings? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_client_settings(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_http_headers(
HttpHeaders? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_http_headers(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_proxy_settings(
ProxySettings? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_proxy_settings(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_redirect_settings(
RedirectSettings? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_redirect_settings(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_timeout_settings(
TimeoutSettings? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_timeout_settings(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_tls_settings(
TlsSettings? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_tls_settings(self, serializer);
}
}
@protected
void sse_encode_opt_box_autoadd_tls_version(
TlsVersion? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_box_autoadd_tls_version(self, serializer);
}
}
@protected
void sse_encode_opt_list_prim_u_8_strict(
Uint8List? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_list_prim_u_8_strict(self, serializer);
}
}
@protected
void sse_encode_opt_list_record_string_string(
List<(String, String)>? self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self != null, serializer);
if (self != null) {
sse_encode_list_record_string_string(self, serializer);
}
}
@protected
void sse_encode_proxy_condition(
ProxyCondition self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.index, serializer);
}
@protected
void sse_encode_proxy_settings(ProxySettings self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
switch (self) {
case ProxySettings_NoProxy():
sse_encode_i_32(0, serializer);
case ProxySettings_CustomProxyList(field0: final field0):
sse_encode_i_32(1, serializer);
sse_encode_list_custom_proxy(field0, serializer);
}
}
@protected
void sse_encode_record_string_list_string(
(String, List<String>) self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.$1, serializer);
sse_encode_list_String(self.$2, serializer);
}
@protected
void sse_encode_record_string_string(
(String, String) self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_String(self.$1, serializer);
sse_encode_String(self.$2, serializer);
}
@protected
void sse_encode_redirect_settings(
RedirectSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
switch (self) {
case RedirectSettings_NoRedirect():
sse_encode_i_32(0, serializer);
case RedirectSettings_LimitedRedirects(field0: final field0):
sse_encode_i_32(1, serializer);
sse_encode_i_32(field0, serializer);
}
}
@protected
void sse_encode_rhttp_error(RhttpError self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
switch (self) {
case RhttpError_RhttpCancelError():
sse_encode_i_32(0, serializer);
case RhttpError_RhttpTimeoutError():
sse_encode_i_32(1, serializer);
case RhttpError_RhttpRedirectError():
sse_encode_i_32(2, serializer);
case RhttpError_RhttpStatusCodeError(
field0: final field0,
field1: final field1,
field2: final field2,
):
sse_encode_i_32(3, serializer);
sse_encode_u_16(field0, serializer);
sse_encode_list_record_string_string(field1, serializer);
sse_encode_box_autoadd_http_response_body(field2, serializer);
case RhttpError_RhttpInvalidCertificateError(field0: final field0):
sse_encode_i_32(4, serializer);
sse_encode_String(field0, serializer);
case RhttpError_RhttpConnectionError(field0: final field0):
sse_encode_i_32(5, serializer);
sse_encode_String(field0, serializer);
case RhttpError_RhttpUnknownError(field0: final field0):
sse_encode_i_32(6, serializer);
sse_encode_String(field0, serializer);
}
}
@protected
void sse_encode_static_dns_settings(
StaticDnsSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_Map_String_list_String_None(self.overrides, serializer);
sse_encode_opt_String(self.fallback, serializer);
}
@protected
void sse_encode_timeout_settings(
TimeoutSettings self,
SseSerializer serializer,
) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_opt_box_autoadd_Chrono_Duration(self.timeout, serializer);
sse_encode_opt_box_autoadd_Chrono_Duration(self.connectTimeout, serializer);
sse_encode_opt_box_autoadd_Chrono_Duration(
self.keepAliveTimeout,
serializer,
);
sse_encode_opt_box_autoadd_Chrono_Duration(self.keepAlivePing, serializer);
}
@protected
void sse_encode_tls_settings(TlsSettings self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_bool(self.trustRootCertificates, serializer);
sse_encode_list_list_prim_u_8_strict(
self.trustedRootCertificates,
serializer,
);
sse_encode_bool(self.verifyCertificates, serializer);
sse_encode_opt_box_autoadd_client_certificate(
self.clientCertificate,
serializer,
);
sse_encode_opt_box_autoadd_tls_version(self.minTlsVersion, serializer);
sse_encode_opt_box_autoadd_tls_version(self.maxTlsVersion, serializer);
}
@protected
void sse_encode_tls_version(TlsVersion self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
sse_encode_i_32(self.index, serializer);
}
@protected
void sse_encode_u_16(int self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putUint16(self);
}
@protected
void sse_encode_u_8(int self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putUint8(self);
}
@protected
void sse_encode_unit(void self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
}
@protected
void sse_encode_usize(BigInt self, SseSerializer serializer) {
// Codec=Sse (Serialization based), see doc to use other codecs
serializer.buffer.putBigUint64(self);
}
}
@sealed
class CancellationTokenImpl extends RustOpaque implements CancellationToken {
// Not to be used by end users
CancellationTokenImpl.frbInternalDcoDecode(List<dynamic> wire)
: super.frbInternalDcoDecode(wire, _kStaticData);
// Not to be used by end users
CancellationTokenImpl.frbInternalSseDecode(
BigInt ptr,
int externalSizeOnNative,
) : super.frbInternalSseDecode(ptr, externalSizeOnNative, _kStaticData);
static final _kStaticData = RustArcStaticData(
rustArcIncrementStrongCount:
RustLib.instance.api.rust_arc_increment_strong_count_CancellationToken,
rustArcDecrementStrongCount:
RustLib.instance.api.rust_arc_decrement_strong_count_CancellationToken,
rustArcDecrementStrongCountPtr: RustLib
.instance
.api
.rust_arc_decrement_strong_count_CancellationTokenPtr,
);
}
@sealed
class DnsSettingsImpl extends RustOpaque implements DnsSettings {
// Not to be used by end users
DnsSettingsImpl.frbInternalDcoDecode(List<dynamic> wire)
: super.frbInternalDcoDecode(wire, _kStaticData);
// Not to be used by end users
DnsSettingsImpl.frbInternalSseDecode(BigInt ptr, int externalSizeOnNative)
: super.frbInternalSseDecode(ptr, externalSizeOnNative, _kStaticData);
static final _kStaticData = RustArcStaticData(
rustArcIncrementStrongCount:
RustLib.instance.api.rust_arc_increment_strong_count_DnsSettings,
rustArcDecrementStrongCount:
RustLib.instance.api.rust_arc_decrement_strong_count_DnsSettings,
rustArcDecrementStrongCountPtr:
RustLib.instance.api.rust_arc_decrement_strong_count_DnsSettingsPtr,
);
}
@sealed
class RequestClientImpl extends RustOpaque implements RequestClient {
// Not to be used by end users
RequestClientImpl.frbInternalDcoDecode(List<dynamic> wire)
: super.frbInternalDcoDecode(wire, _kStaticData);
// Not to be used by end users
RequestClientImpl.frbInternalSseDecode(BigInt ptr, int externalSizeOnNative)
: super.frbInternalSseDecode(ptr, externalSizeOnNative, _kStaticData);
static final _kStaticData = RustArcStaticData(
rustArcIncrementStrongCount:
RustLib.instance.api.rust_arc_increment_strong_count_RequestClient,
rustArcDecrementStrongCount:
RustLib.instance.api.rust_arc_decrement_strong_count_RequestClient,
rustArcDecrementStrongCountPtr:
RustLib.instance.api.rust_arc_decrement_strong_count_RequestClientPtr,
);
}