Skip to content

Commit

Permalink
compound names
Browse files Browse the repository at this point in the history
  • Loading branch information
l3r8yJ committed Apr 9, 2023
1 parent 819d92f commit 74cbc66
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -53,19 +53,19 @@ final class KfConsumerTest {

@Test
void subscribes(
@Mock final ConsumerSettings<String, String> settingsMock,
@Mock final KafkaConsumer<String, String> consumerMock
@Mock final ConsumerSettings<String, String> settings,
@Mock final KafkaConsumer<String, String> consumer
) {
Mockito.when(settingsMock.consumer()).thenReturn(consumerMock);
final Consumer<String, String> consumer = new KfConsumer<>(settingsMock);
Mockito.when(settings.consumer()).thenReturn(consumer);
final Consumer<String, String> underTest = new KfConsumer<>(settings);
assertDoesNotThrow(
() ->
consumer.subscribe(
underTest.subscribe(
new ListOf<>("transactions-info")
)
);
assertDoesNotThrow(
consumer::close
underTest::close
);
}

Expand Down

0 comments on commit 74cbc66

Please sign in to comment.