import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.ListenableFuture;
import java.util.List;
import java.util.Map;
import java.util.Set;
return this.ribImpl.getService();
}
+ public ListenableFuture<Void> closeServiceInstance() {
+ if (this.ribImpl != null) {
+ return this.ribImpl.closeServiceInstance();
+ }
+ return Futures.immediateFuture(null);
+ }
+
@Override
public void close() {
if (this.ribImpl != null) {