getResponseAsync method

@override Stream<String> getResponseAsync()

Implementation

@override
Stream<String> getResponseAsync() {
  if (kDebugMode) {
    debugPrint('🌊 getResponseAsync: Starting async response generation');
  }

  _controller = StreamController<String>();

  try {
    final promptArray = _createPromptArray();

    if (kDebugMode) {
      debugPrint('🎯 getResponseAsync: Prompt array type: ${promptArray.runtimeType}');
      debugPrint('🎯 getResponseAsync: Is JSString? ${promptArray is JSString}');
    }

    // Use appropriate method based on prompt type
    if (promptArray is JSString) {
      if (kDebugMode) {
        debugPrint('📝 getResponseAsync: Using generateResponse for text-only prompt');
      }
      llmInference.generateResponse(
        promptArray,
        ((JSString partialJs, JSAny completeRaw) {
          try {
            final complete = completeRaw.parseBool();
            final partial = partialJs.toDart;
            if (kDebugMode) {
              debugPrint(
                  '📝 getResponseAsync: Received partial (complete: $complete): ${partial.substring(0, math.min(50, partial.length))}...');
            }
            _controller?.add(partial);
            if (complete) {
              if (kDebugMode) {
                debugPrint('✅ getResponseAsync: Text response completed');
              }
              _controller?.close();
            }
          } catch (e) {
            if (kDebugMode) {
              debugPrint('❌ getResponseAsync: Error in text callback: $e');
            }
            _controller?.addError(e);
          }
        }).toJS,
      );
    } else {
      if (kDebugMode) {
        debugPrint(
            '🖼️ getResponseAsync: Using generateResponseMultimodal for multimodal prompt');
      }
      llmInference.generateResponseMultimodal(
        promptArray,
        ((JSString partialJs, JSAny completeRaw) {
          try {
            final complete = completeRaw.parseBool();
            final partial = partialJs.toDart;
            if (kDebugMode) {
              debugPrint(
                  '🖼️ getResponseAsync: Received multimodal partial (complete: $complete): ${partial.substring(0, math.min(50, partial.length))}...');
            }
            _controller?.add(partial);
            if (complete) {
              if (kDebugMode) {
                debugPrint('✅ getResponseAsync: Multimodal response completed');
              }
              _controller?.close();
            }
          } catch (e) {
            if (kDebugMode) {
              debugPrint('❌ getResponseAsync: Error in multimodal callback: $e');
            }
            _controller?.addError(e);
          }
        }).toJS,
      );
    }
  } catch (e, stackTrace) {
    if (kDebugMode) {
      debugPrint('❌ getResponseAsync: Exception during setup: $e');
      debugPrint('❌ getResponseAsync: Stack trace: $stackTrace');
    }
    _controller?.addError(e);
  }

  return _controller!.stream;
}