public Optional connect()

in src/main/java/com/awslabs/aws/iot/websockets/BasicMqttOverWebsocketsProvider.java [105:111]

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

    public Optional<IMqttToken> connect(MqttAsyncClient mqttAsyncClient, ImmutableUsernamePassword usernamePassword, Object userContext, IMqttActionListener callback) throws MqttException {
        MqttConnectOptions connOpts = new MqttConnectOptions();
        connOpts.setCleanSession(true);
        setUsernamePassword(usernamePassword, connOpts);

        return Optional.of(mqttAsyncClient.connect(connOpts, userContext, callback));
    }