public Optional connect()

in src/main/java/com/awslabs/aws/iot/websockets/BasicMqttOverWebsocketsProvider.java [97:102]

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

    public Optional<IMqttToken> connect(MqttAsyncClient mqttAsyncClient) throws MqttException {
        MqttConnectOptions connOpts = new MqttConnectOptions();
        connOpts.setCleanSession(true);

        return Optional.of(mqttAsyncClient.connect(connOpts));
    }