Package: Callbacks

Callbacks

name	instruction	branch	complexity	line	method
asCallback(CompletableFuture)	M: 5 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*******************************************************************************
2: * Copyright (c) 2017, 2022 Red Hat Inc and others.
3: *
4: * This program and the accompanying materials are made
5: * available under the terms of the Eclipse Public License 2.0
6: * which is available at https://www.eclipse.org/legal/epl-2.0/
7: *
8: * SPDX-License-Identifier: EPL-2.0
9: *
10: * Contributors:
11: * Red Hat Inc - initial API and implementation
12: *******************************************************************************/
13: package org.eclipse.kapua.client.gateway.mqtt.fuse.internal;
14:
15: import java.util.concurrent.CompletableFuture;
16:
17: import org.fusesource.mqtt.client.Callback;
18:
19: public final class Callbacks {
20:
21: private Callbacks() {
22: }
23:
24: public static <T> Callback<T> asCallback(final CompletableFuture<T> future) {
25: return new Callback<T>() {
26:
27: @Override
28: public void onSuccess(T value) {
29: future.complete(value);
30: }
31:
32: @Override
33: public void onFailure(Throwable value) {
34: future.completeExceptionally(value);
35: }
36: };
37: }
38: }