Use `IterableStream<T>(Iterable)` ctor in EventHubProperties #6539

conniey · 2019-11-25T20:49:24Z

Updates EventHubProperties to use IterableStream<T>(Iterable<T>) overload. This fixes the IllegalStateException because we are no longer moving from the Flux universe, into synchronous then back into the Flux world.
Adds back a package-private scheduler override on EventHubClientBuilder and forces our integration tests to use Schedulers.parallel, so we can double check that we don't have blocking calls in our code.

Fixes #6515

...zure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/EventHubProperties.java

conniey added 4 commits November 25, 2019 12:42

Using Iterable overload in EventHubProperties.

14979a9

Adding package-private ctor for Scheduler.

5e5d62f

Update Integration tests to use parallel scheduler.

fde7abd

Add link to GitHub issue.

eded62c

conniey added Event Hubs Client This issue points to a problem in the data-plane of the library. labels Nov 25, 2019

conniey requested a review from srnagar November 25, 2019 20:49

conniey requested a review from mssfang as a code owner November 25, 2019 20:49

conniey self-assigned this Nov 25, 2019

Adding try/catch around producer credential integration tests.

5bc4e60

srnagar approved these changes Nov 25, 2019

View reviewed changes

...zure-messaging-eventhubs/src/main/java/com/azure/messaging/eventhubs/EventHubProperties.java Outdated Show resolved Hide resolved

conniey added 2 commits November 25, 2019 13:26

Update EventHubProperties to throw if is negative.

ffc1fee

Adding tests.

7c30b84

conniey merged commit 7ade319 into Azure:master Nov 25, 2019

conniey deleted the update-eventhubs branch November 25, 2019 21:48

Provide feedback