Fix formatting

Author: rstoyanchev

rsocket-core/src/main/java/io/rsocket/core/RequestOperator.java

@@ -1,6 +1,7 @@
 package io.rsocket.core;
 
 import io.rsocket.Payload;
+import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 import reactor.core.CorePublisher;
@@ -10,8 +11,6 @@
 import reactor.core.publisher.SignalType;
 import reactor.util.context.Context;
 
-import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
-
 /**
  * This is a support class for handling of request input, intended for use with {@link
  * Operators#lift}. It ensures serial execution of cancellation vs first request signals and also

rsocket-core/src/test/java/io/rsocket/core/RSocketTest.java

@@ -16,6 +16,8 @@
 
 package io.rsocket.core;
 
+import static io.rsocket.frame.FrameLengthCodec.FRAME_LENGTH_MASK;
+
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import io.rsocket.Payload;
@@ -31,6 +33,10 @@
 import io.rsocket.test.util.LocalDuplexConnection;
 import io.rsocket.util.DefaultPayload;
 import io.rsocket.util.EmptyPayload;
+import java.time.Duration;
+import java.util.List;
+import java.util.concurrent.CancellationException;
+import java.util.concurrent.atomic.AtomicReference;
 import org.assertj.core.api.Assertions;
 import org.junit.Rule;
 import org.junit.Test;
@@ -46,13 +52,6 @@
 import reactor.test.StepVerifier;
 import reactor.test.publisher.TestPublisher;
 
-import java.time.Duration;
-import java.util.List;
-import java.util.concurrent.CancellationException;
-import java.util.concurrent.atomic.AtomicReference;
-
-import static io.rsocket.frame.FrameLengthCodec.FRAME_LENGTH_MASK;
-
 public class RSocketTest {
 
   @Rule public final SocketRule rule = new SocketRule();