Skip to content

Commit

Permalink
Test RC fix (#2843)
Browse files Browse the repository at this point in the history
Signed-off-by: Daniel Kec <daniel.kec@oracle.com>
  • Loading branch information
danielkec authored Mar 9, 2021
1 parent ae4317f commit 83b74b5
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright (c) 2017, 2020 Oracle and/or its affiliates.
* Copyright (c) 2017, 2021 Oracle and/or its affiliates.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -83,7 +83,7 @@ void testReadAllData() {
}

@Test
void testChunky() {
void testChunky() throws InterruptedException {
PeriodicalChannel pc = createChannelWithNoAvailableData(25, 3);
Multi<ByteBuffer> publisher = IoMulti.multiFromByteChannelBuilder(pc)
.retrySchema(RetrySchema.constant(2))
Expand All @@ -102,6 +102,7 @@ void testChunky() {
MultiFromByteChannel multi = (MultiFromByteChannel) publisher;
LazyValue<ScheduledExecutorService> executor = multi.executor();
assertThat("Executor should have been used", executor.isLoaded(), is(true));
assertThat("Executor didn't terminate in time", executor.get().awaitTermination(5, TimeUnit.SECONDS), is(true));
assertThat("Executor should have been shut down", executor.get().isShutdown(), is(true));
}

Expand Down

0 comments on commit 83b74b5

Please sign in to comment.