Skip to content

Commit

Permalink
Fixed JavaTest
Browse files Browse the repository at this point in the history
Signed-off-by: Mingela <freekilluau@gmail.com>
  • Loading branch information
Mingela committed Aug 1, 2023
1 parent 280ba1c commit 9e5d429
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -170,8 +170,9 @@ public void setKeyValue() throws Exception {
@ResourceLock("blockStream")
public void blockStreaming() throws ExecutionException, InterruptedException {
int count = 5;
Pair<UUID, BlockStreamSubscription> idToSubscription = client.subscribeToBlockStreamBlocking(1, count);
UUID actionId = idToSubscription.component1();
Pair<Iterable<BlockStreamStorage>, BlockStreamSubscription> idToSubscription =
client.subscribeToBlockStreamBlocking(1, count);
UUID actionId = idToSubscription.component1().iterator().next().getId();
BlockStreamSubscription subscription = idToSubscription.component2();

List<VersionedBlockMessage> blocks = new ArrayList<>();
Expand Down

0 comments on commit 9e5d429

Please sign in to comment.