CompletableFuture start()

in src/backend/transcriber/src/main/java/com/amazonaws/transcriber/Transcriber.java [60:76]

• 17 lines of code
• 3 McCabe index (conditional complexity)

    CompletableFuture<Void> start(InputStream inputStream) {
        if (audioStreamPublisher != null) {
            throw new IllegalStateException("Already running");
        }
        TranscribeStreamingAsyncClient asyncClient = TranscribeStreamingAsyncClient.create();
        retryClient = new TranscribeStreamingRetryClient(asyncClient);
        StartStreamTranscriptionRequest.Builder requestBuilder = StartStreamTranscriptionRequest.builder()
            .languageCode(language.toString())
            .mediaEncoding(encoding)
            .mediaSampleRateHertz(sampleRate);
        if (!Strings.isNullOrEmpty(vocabularyName)) {
            requestBuilder.vocabularyName(vocabularyName);
        }
        StartStreamTranscriptionRequest request = requestBuilder.build();
        audioStreamPublisher = new AudioStreamPublisher(new BufferedInputStream(inputStream));
        return retryClient.startStreamTranscription(request, audioStreamPublisher, handler);
    }