crateApiLoggerSendToDartLoggerSetStreamSink method

Implementation

@override
Stream<LogEntry> crateApiLoggerSendToDartLoggerSetStreamSink() {
  final streamSink = RustStreamSink<LogEntry>();
  unawaited(
    handler.executeNormal(
      NormalTask(
        callFfi: (port_) {
          final serializer = SseSerializer(generalizedFrbRustBinding);
          sse_encode_StreamSink_log_entry_Sse(streamSink, serializer);
          pdeCallFfi(
            generalizedFrbRustBinding,
            serializer,
            funcId: 6,
            port: port_,
          );
        },
        codec: SseCodec(
          decodeSuccessData: sse_decode_unit,
          decodeErrorData: null,
        ),
        constMeta: kCrateApiLoggerSendToDartLoggerSetStreamSinkConstMeta,
        argValues: [streamSink],
        apiImpl: this,
      ),
    ),
  );
  return streamSink.stream;
}