private StartStreamTranscriptionResponseHandler getResponseHandler()

in src/backend/transcriber/src/main/java/com/amazonaws/transcribestreaming/retryclient/TranscribeStreamingRetryClient.java [185:198]

• 12 lines of code
• 1 McCabe index (conditional complexity)

    private StartStreamTranscriptionResponseHandler getResponseHandler(
            StreamTranscriptionBehavior transcriptionBehavior) {
        final StartStreamTranscriptionResponseHandler build = StartStreamTranscriptionResponseHandler.builder()
                .onResponse(transcriptionBehavior::onResponse)
                .onError(e -> {
                    //Do nothing here. Make sure you don't close any streams that should not be cleaned up yet.
                })
                .onComplete(() -> {
                    //Do nothing here. Make sure you don't close any streams that should not be cleaned up yet.
                })
                .subscriber(transcriptionBehavior::onStream)
                .build();
        return build;
    }