@@ -171,11 +171,11 @@ public static class Listener<T> extends Container.Base implements Predicate<Even
171171 @ NonFinal boolean active = true ;
172172
173173 private Listener (@ Nullable String key , @ NotNull Bus <T > bus , Predicate <Event <T >> requirement , Consumer <Event <T >> action ) {
174- this .name = key ;
175- this .bus = bus ;
174+ this .name = key ;
175+ this .bus = bus ;
176176 this .requirement = requirement ;
177- this .action = action ;
178- this .location = caller (2 );
177+ this .action = action ;
178+ this .location = caller (2 );
179179 }
180180
181181 @ Override
@@ -327,7 +327,7 @@ private <I> Bus<T> setDependent(
327327 ) {
328328 if (cleanup && this .upstream != null ) this .upstream .downstream .remove (this );
329329 this .upstream = parent ;
330- this .function = uncheckedCast (function );
330+ this .function = uncheckedCast (function );
331331 this .keyFunction = keyFunction ;
332332 this .upstream .downstream .add (this );
333333 return this ;
@@ -407,7 +407,7 @@ public Event<T> publish(@Nullable String key, @Nullable T data) {
407407 @ Builder (builderClassName = "Publisher" , buildMethodName = "publish" , builderMethodName = "publisher" )
408408 public Event <T > publish (@ Nullable String key , @ Nullable Long flag_ , @ Nullable T data ) {
409409 if (!active ) return null ;
410- final var flag = flag_ == null ? Subscriber .DefaultFlag : flag_ ;
410+ final var flag = flag_ == null ? Subscriber .DefaultFlag : flag_ ;
411411 final var event = factory .apply (data , key , flag );
412412 accept (event );
413413 return event ;
@@ -454,7 +454,7 @@ private void publish(Event<T> event) {
454454 private <P > void $publishDownstream (final Event <P > data ) {
455455 if (function == null ) return ;
456456 Function <@ NotNull Event <P >, @ Nullable Event <T >> func = uncheckedCast (function );
457- var it = func .apply (data );
457+ var it = func .apply (data );
458458 if (it == null ) return ;
459459 accept (it );
460460 }
@@ -464,7 +464,7 @@ private class SubscriberImpl implements Predicate<Event<T>>, BiConsumer<@Nullabl
464464 String key ;
465465 long flag ;
466466 Subscriber .FlagMode mode ;
467- Invocable <?> delegate ;
467+ Invocable <?> delegate ;
468468
469469 @ Override
470470 public boolean test (Event <T > event ) {
@@ -499,7 +499,7 @@ private class SubscriberListener extends Listener<T> {
499499
500500 public SubscriberListener (@ Nullable Object target , Collection <SubscriberImpl > subscribers ) {
501501 super (null , Bus .this , $ -> true , $ -> {});
502- this .target = target ;
502+ this .target = target ;
503503 this .subscribers = subscribers ;
504504 }
505505
0 commit comments