*/
package org.opendaylight.yangtools.yang.common;
+import static java.util.Objects.requireNonNull;
+
import com.google.common.collect.ImmutableList;
import com.google.common.util.concurrent.FluentFuture;
import com.google.common.util.concurrent.Futures;
import java.io.Serializable;
import java.util.Collection;
+import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.yangtools.concepts.Builder;
import org.opendaylight.yangtools.yang.common.RpcError.ErrorSeverity;
import org.opendaylight.yangtools.yang.common.RpcError.ErrorType;
private static class RpcResultImpl<T> implements RpcResult<T>, Serializable {
private static final long serialVersionUID = 1L;
- private final Collection<RpcError> errors;
+ private final ImmutableList<RpcError> errors;
private final T result;
private final boolean successful;
- RpcResultImpl(final boolean successful, final T result,
- final Collection<RpcError> errors) {
+ RpcResultImpl(final boolean successful, final T result, final ImmutableList<RpcError> errors) {
this.successful = successful;
this.result = result;
- this.errors = errors;
+ this.errors = requireNonNull(errors);
}
@Override
- public Collection<RpcError> getErrors() {
+ public ImmutableList<RpcError> getErrors() {
return errors;
}
/**
* Returns a builder for a successful result.
*/
- public static <T> RpcResultBuilder<T> success() {
+ public static <T> @NonNull RpcResultBuilder<T> success() {
return new RpcResultBuilder<>(true, null);
}
*
* @param result the result value
*/
- public static <T> RpcResultBuilder<T> success(final T result) {
+ public static <T> @NonNull RpcResultBuilder<T> success(final T result) {
return new RpcResultBuilder<>(true, result);
}
*
* @param builder builder for the result value
*/
- public static <T> RpcResultBuilder<T> success(final Builder<T> builder) {
+ public static <T> @NonNull RpcResultBuilder<T> success(final Builder<T> builder) {
return success(builder.build());
}
/**
* Returns a builder for a failed result.
*/
- public static <T> RpcResultBuilder<T> failed() {
+ public static <T> @NonNull RpcResultBuilder<T> failed() {
return new RpcResultBuilder<>(false, null);
}
*
* @param success true if successful, false otherwise.
*/
- public static <T> RpcResultBuilder<T> status(final boolean success) {
+ public static <T> @NonNull RpcResultBuilder<T> status(final boolean success) {
return new RpcResultBuilder<>(success, null);
}
*
* @param other the other RpcResult.
*/
- public static <T> RpcResultBuilder<T> from(final RpcResult<T> other) {
+ public static <T> @NonNull RpcResultBuilder<T> from(final RpcResult<T> other) {
return new RpcResultBuilder<>(other.isSuccessful(), other.getResult())
.withRpcErrors(other.getErrors());
}
*
* @return an RpcError
*/
- public static RpcError newError(final ErrorType errorType, final String tag, final String message) {
+ public static @NonNull RpcError newError(final ErrorType errorType, final String tag, final String message) {
return new RpcErrorImpl(ErrorSeverity.ERROR, errorType,
tag != null ? tag : "operation-failed", message, null, null, null);
}
*
* @return an RpcError
*/
- public static RpcError newError(final ErrorType errorType, final String tag, final String message,
+ public static @NonNull RpcError newError(final ErrorType errorType, final String tag, final String message,
final String applicationTag, final String info, final Throwable cause) {
return new RpcErrorImpl(ErrorSeverity.ERROR, errorType,
tag != null ? tag : "operation-failed", message, applicationTag, info, cause);
*
* @return an RpcError
*/
- public static RpcError newWarning(final ErrorType errorType, final String tag, final String message) {
+ public static @NonNull RpcError newWarning(final ErrorType errorType, final String tag, final String message) {
return new RpcErrorImpl(ErrorSeverity.WARNING, errorType, tag, message, null, null, null);
}
*
* @return an RpcError
*/
- public static RpcError newWarning(final ErrorType errorType, final String tag, final String message,
+ public static @NonNull RpcError newWarning(final ErrorType errorType, final String tag, final String message,
final String applicationTag, final String info, final Throwable cause) {
return new RpcErrorImpl(ErrorSeverity.WARNING, errorType, tag, message,
applicationTag, info, cause);
* @param result the result value
*/
@SuppressWarnings("checkstyle:hiddenField")
- public RpcResultBuilder<T> withResult(final T result) {
+ public @NonNull RpcResultBuilder<T> withResult(final T result) {
this.result = result;
return this;
}
*
* @param builder builder for the result value
*/
- public RpcResultBuilder<T> withResult(final Builder<T> builder) {
+ public @NonNull RpcResultBuilder<T> withResult(final Builder<T> builder) {
return withResult(builder.build());
}
* {@link RpcError#getTag} for a list of suggested values.
* @param message a string suitable for human display that describes the warning condition.
*/
- public RpcResultBuilder<T> withWarning(final ErrorType errorType, final String tag, final String message) {
+ public @NonNull RpcResultBuilder<T> withWarning(final ErrorType errorType, final String tag, final String message) {
addError(ErrorSeverity.WARNING, errorType, tag, message, null, null, null);
return this;
}
* and/or implementation-specific debugging information.
* @param cause the exception that triggered the warning.
*/
- public RpcResultBuilder<T> withWarning(final ErrorType errorType, final String tag, final String message,
+ public @NonNull RpcResultBuilder<T> withWarning(final ErrorType errorType, final String tag, final String message,
final String applicationTag, final String info, final Throwable cause) {
addError(ErrorSeverity.WARNING, errorType, tag, message, applicationTag, info, cause);
return this;
* @param errorType the conceptual layer at which the error occurred.
* @param message a string suitable for human display that describes the error condition.
*/
- public RpcResultBuilder<T> withError(final ErrorType errorType, final String message) {
+ public @NonNull RpcResultBuilder<T> withError(final ErrorType errorType, final String message) {
addError(ErrorSeverity.ERROR, errorType, null, message, null, null, null);
return this;
}
* {@link RpcError#getTag} for a list of suggested values.
* @param message a string suitable for human display that describes the error condition.
*/
- public RpcResultBuilder<T> withError(final ErrorType errorType, final String tag, final String message) {
+ public @NonNull RpcResultBuilder<T> withError(final ErrorType errorType, final String tag, final String message) {
addError(ErrorSeverity.ERROR, errorType, tag, message, null, null, null);
return this;
}
* @param message a string suitable for human display that describes the error condition.
* @param cause the exception that triggered the error.
*/
- public RpcResultBuilder<T> withError(final ErrorType errorType, final String message,
+ public @NonNull RpcResultBuilder<T> withError(final ErrorType errorType, final String message,
final Throwable cause) {
addError(ErrorSeverity.ERROR, errorType, null, message, null, null, cause);
return this;
* and/or implementation-specific debugging information.
* @param cause the exception that triggered the error.
*/
- public RpcResultBuilder<T> withError(final ErrorType errorType, final String tag, final String message,
+ public @NonNull RpcResultBuilder<T> withError(final ErrorType errorType, final String tag, final String message,
final String applicationTag, final String info, final Throwable cause) {
addError(ErrorSeverity.ERROR, errorType, tag, message, applicationTag, info, cause);
return this;
*
* @param error the RpcError
*/
- public RpcResultBuilder<T> withRpcError(final RpcError error) {
+ public @NonNull RpcResultBuilder<T> withRpcError(final RpcError error) {
addError(error);
return this;
}
*
* @return Future for RpcResult built by RpcResultBuilder
*/
- public FluentFuture<RpcResult<T>> buildFuture() {
+ public @NonNull FluentFuture<RpcResult<T>> buildFuture() {
return FluentFuture.from(Futures.immediateFuture(build()));
}
}