Skip to content

Commit

Permalink
Make Barrage URI resolver return a Table (#4732)
Browse files Browse the repository at this point in the history
Fixes #4730
  • Loading branch information
devinrsmith committed Oct 27, 2023
1 parent efe0664 commit 0b289ba
Showing 1 changed file with 6 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
*/
package io.deephaven.server.uri;

import io.deephaven.UncheckedDeephavenException;
import io.deephaven.client.impl.*;
import io.deephaven.client.impl.TableHandle.TableHandleException;
import io.deephaven.configuration.Configuration;
Expand Down Expand Up @@ -31,6 +32,7 @@
import java.net.URI;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;

Expand Down Expand Up @@ -103,11 +105,13 @@ public boolean isResolvable(URI uri) {
}

@Override
public Future<Table> resolve(URI uri) throws InterruptedException {
public Table resolve(URI uri) throws InterruptedException {
try {
return subscribe(RemoteUri.of(uri));
return subscribe(RemoteUri.of(uri)).get();
} catch (TableHandleException e) {
throw e.asUnchecked();
} catch (ExecutionException e) {
throw new UncheckedDeephavenException(e);
}
}

Expand Down

0 comments on commit 0b289ba

Please sign in to comment.