crateApiSimpleRegisterCallStream method

@override Stream<CallInfo> crateApiSimpleRegisterCallStream()

Implementation

@override
Stream<CallInfo> crateApiSimpleRegisterCallStream() {
  final callSink = RustStreamSink<CallInfo>();
  unawaited(
    handler.executeNormal(
      NormalTask(
        callFfi: (port_) {
          final serializer = SseSerializer(generalizedFrbRustBinding);
          sse_encode_StreamSink_call_info_Sse(callSink, serializer);
          pdeCallFfi(generalizedFrbRustBinding, serializer, funcId: 9, port: port_);
        },
        codec: SseCodec(decodeSuccessData: sse_decode_unit, decodeErrorData: null),
        constMeta: kCrateApiSimpleRegisterCallStreamConstMeta,
        argValues: [callSink],
        apiImpl: this,
      ),
    ),
  );
  return callSink.stream;
}