public void request()

in src/main/java/com/amazonaws/lex/twilio/sample/streaming/AudioEventsSubscription.java [61:71]

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

    public void request(long demand) {
        // start a thread to write events, if it has not been started so far.
        if (eventWriterFuture == null) {
            eventWriterFuture = CompletableFuture.runAsync(eventWriter).whenComplete((result, error) -> {
                if (error != null) {
                    error.printStackTrace();
                }
            });
        }
        eventWriter.addDemand(demand);
    }