diff --git a/reactor-core/src/main/java/reactor/core/publisher/SinkManySerialized.java b/reactor-core/src/main/java/reactor/core/publisher/SinkManySerialized.java index 940708b11a..c2a3d7be3a 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/SinkManySerialized.java +++ b/reactor-core/src/main/java/reactor/core/publisher/SinkManySerialized.java @@ -54,7 +54,7 @@ public boolean isCancelled() { } @Override - public final Sinks.EmitResult tryEmitComplete() { + public Sinks.EmitResult tryEmitComplete() { Thread currentThread = Thread.currentThread(); if (!tryAcquire(currentThread)) { return Sinks.EmitResult.FAIL_NON_SERIALIZED; @@ -70,7 +70,7 @@ public final Sinks.EmitResult tryEmitComplete() { } @Override - public final Sinks.EmitResult tryEmitError(Throwable t) { + public Sinks.EmitResult tryEmitError(Throwable t) { Objects.requireNonNull(t, "t is null in sink.error(t)"); Thread currentThread = Thread.currentThread(); @@ -88,7 +88,7 @@ public final Sinks.EmitResult tryEmitError(Throwable t) { } @Override - public final Sinks.EmitResult tryEmitNext(T t) { + public Sinks.EmitResult tryEmitNext(T t) { Objects.requireNonNull(t, "t is null in sink.next(t)"); Thread currentThread = Thread.currentThread();