Expose completion future from WriteOperations
[mdsal.git] / binding / mdsal-binding-spi / src / main / java / org / opendaylight / mdsal / binding / spi / ForwardingReadWriteTransaction.java
1 /*
2  * Copyright © 2017, 2018 Red Hat, Inc. and others.
3  *
4  * This program and the accompanying materials are made available under the
5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6  * and is available at http://www.eclipse.org/legal/epl-v10.html
7  */
8 package org.opendaylight.mdsal.binding.spi;
9
10 import static java.util.Objects.requireNonNull;
11
12 import com.google.common.util.concurrent.FluentFuture;
13 import java.util.Optional;
14 import org.opendaylight.mdsal.binding.api.ReadWriteTransaction;
15 import org.opendaylight.mdsal.common.api.CommitInfo;
16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
17 import org.opendaylight.yangtools.yang.binding.DataObject;
18 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
19
20 /**
21  * Utility {@link ReadWriteTransaction} implementation which forwards all interface method invocation to a delegate
22  * instance.
23  */
24 public class ForwardingReadWriteTransaction extends ForwardingTransaction implements ReadWriteTransaction {
25     private final ReadWriteTransaction delegate;
26
27     public ForwardingReadWriteTransaction(final ReadWriteTransaction delegate) {
28         this.delegate = requireNonNull(delegate);
29     }
30
31     @Override
32     protected ReadWriteTransaction delegate() {
33         return delegate;
34     }
35
36     @Override
37     public <T extends DataObject> void put(final LogicalDatastoreType store, final InstanceIdentifier<T> path,
38             final T data) {
39         delegate.put(store, path, data);
40     }
41
42     @Deprecated
43     @Override
44     public <T extends DataObject> void mergeParentStructurePut(final LogicalDatastoreType store,
45             final InstanceIdentifier<T> path, final T data) {
46         delegate.mergeParentStructurePut(store, path, data);
47     }
48
49     @Override
50     public <T extends DataObject> FluentFuture<Optional<T>> read(final LogicalDatastoreType store,
51             final InstanceIdentifier<T> path) {
52         return delegate.read(store, path);
53     }
54
55     @Override
56     public FluentFuture<Boolean> exists(final LogicalDatastoreType store, final InstanceIdentifier<?> path) {
57         return delegate.exists(store, path);
58     }
59
60     @Override
61     public boolean cancel() {
62         return delegate.cancel();
63     }
64
65     @Override
66     public <T extends DataObject> void merge(final LogicalDatastoreType store, final InstanceIdentifier<T> path,
67             final T data) {
68         delegate.merge(store, path, data);
69     }
70
71     @Deprecated
72     @Override
73     public <T extends DataObject> void mergeParentStructureMerge(final LogicalDatastoreType store,
74             final InstanceIdentifier<T> path, final T data) {
75         delegate.mergeParentStructureMerge(store, path, data);
76     }
77
78     @Override
79     public FluentFuture<? extends CommitInfo> commit() {
80         return delegate.commit();
81     }
82
83     @Override
84     public void delete(final LogicalDatastoreType store, final InstanceIdentifier<?> path) {
85         delegate.delete(store, path);
86     }
87
88     @Override
89     public FluentFuture<?> completionFuture() {
90         return delegate.completionFuture();
91     }
92 }