Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
joshiste committed Mar 18, 2018
1 parent a98d95d commit 8ef0059
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ private static class TestNotifier implements Notifier {

private TestNotifier() {
UnicastProcessor<InstanceEvent> unicastProcessor = UnicastProcessor.create();
this.publishedFlux = unicastProcessor.publish().autoConnect(0);
this.publishedFlux = unicastProcessor;
this.sink = unicastProcessor.sink();
}

Expand Down

0 comments on commit 8ef0059

Please sign in to comment.