Skip to content

Commit

Permalink
Fix typo in variable name
Browse files Browse the repository at this point in the history
  • Loading branch information
dain committed Jul 10, 2018
1 parent eeaafc8 commit 6f72f25
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -516,17 +516,17 @@ private ExecutionFailureInfo rewriteTransportFailure(ExecutionFailureInfo execut
private static class ListenerManager<T>
{
private final List<Consumer<T>> listeners = new ArrayList<>();
private boolean freezed;
private boolean frozen;

public synchronized void addListener(Consumer<T> listener)
{
checkState(!freezed, "Listeners have been invoked");
checkState(!frozen, "Listeners have been invoked");
listeners.add(listener);
}

public synchronized void invoke(T payload, Executor executor)
{
freezed = true;
frozen = true;
for (Consumer<T> listener : listeners) {
executor.execute(() -> listener.accept(payload));
}
Expand Down

0 comments on commit 6f72f25

Please sign in to comment.