silentbalanceyh/vertx-zero

Avoid too many return statements within this method.

Open

            return false;

Avoid too many return statements within this method.

Open

                return false;

Identical blocks of code found in 3 locations. Consider refactoring.

Open

            if (this.responseStatusBuilder_ == null) {
                result.responseStatus_ = this.responseStatus_;
            } else {
                result.responseStatus_ = this.responseStatusBuilder_.build();
            }

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

        return Fn.combineT(futures).compose(listMap -> {
            final ConcurrentMap<String, JsonArray> response = new ConcurrentHashMap<>();
            listMap.forEach(response::putAll);
            return Ux.future(response);
        });

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

            if (this.envelopBuilder_ == null) {
                result.envelop_ = this.envelop_;
            } else {
                result.envelop_ = this.envelopBuilder_.build();
            }

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

            if (this.envelopBuilder_ == null) {
                result.envelop_ = this.envelop_;
            } else {
                result.envelop_ = this.envelopBuilder_.build();
            }

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

        return Fn.combineT(futures).compose(result -> {
            final Set<T> entitySet = new HashSet<>();
            result.forEach(entitySet::addAll);
            return Ux.future(entitySet);
        });

• Read up
  Read up

Identical blocks of code found in 3 locations. Consider refactoring.

Open

            return Fn.combineT(futures).compose(matrix -> {
                final List<SVisitant> visitants = new ArrayList<>();
                matrix.forEach(visitants::addAll);
                return Ux.future(visitants);
            });

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        groups.stream().filter(Objects::nonNull)
            .map(item -> (JsonObject) item)
            .map(ProfileGroup::new)
            .map(ProfileGroup::initAsync)
            .forEach(futures::add);

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

        if (this.algorithm_ != io.vertx.mod.ipc.eon.em.Compression.NONE.getNumber()) {
            output.writeEnum(7, this.algorithm_);
        }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        } finally {
            if (((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
                responseParams_ = java.util.Collections.unmodifiableList(responseParams_);
            }
            makeExtensionsImmutable();

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

package io.horizon.exception.web;

import io.horizon.annotations.Development;
import io.horizon.eon.em.web.HttpStatusCode;
import io.horizon.exception.WebException;

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        for (final MediaType type : consumes) {
            final String item = type.getType() + VString.SLASH + type.getSubtype();
            route.consumes(item);
        }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            .subscribe(method -> {
                final Annotation annotation = method.getAnnotation(Ipc.class);
                final String address = Ut.invoke(annotation, "value");
                addresses.put(address, method);
            })

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            item.fieldNames().stream().filter(field -> field.startsWith(prefix))
                .forEach(key -> this.input.put(key, item.getValue(key)));

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

        public Builder setType(final io.vertx.mod.ipc.eon.em.Format value) {
            if (value == null) {
                throw new NullPointerException();
            }

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

        public Builder setAlgorithm(final io.vertx.mod.ipc.eon.em.Compression value) {
            if (value == null) {
                throw new NullPointerException();
            }

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

package io.horizon.exception.web;

import io.horizon.annotations.Development;
import io.horizon.eon.em.web.HttpStatusCode;
import io.horizon.exception.WebException;

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        if (Ut.isNotNil(added)) {
            final String prefix = Ut.valueString(ruleConfig, ChangeFlag.ADD.name());
            this.messageFormat(message, added, prefix);
        }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        } finally {
            if (((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
                backoffMs_ = java.util.Collections.unmodifiableList(backoffMs_);
            }
            makeExtensionsImmutable();

• Read up
  Read up