Reverted trivial deprecations

Author: artem-v

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java

@@ -148,13 +148,13 @@ public static Mono<Transport> bind(TransportConfig config) {
    */
   @Override
   public Mono<Transport> start() {
-    return Mono.deferContextual(context -> receiver.bind())
+    return Mono.deferWithContext(context -> receiver.bind())
         .doOnNext(this::init)
         .doOnSuccess(t -> LOGGER.info("[bind0][{}] Bound cluster transport", t.address()))
         .doOnError(ex -> LOGGER.error("[bind0][{}] Exception occurred: {}", address, ex.toString()))
         .thenReturn(this)
         .cast(Transport.class)
-        .contextWrite(
+        .subscriberContext(
             context ->
                 context.put(
                     ReceiverContext.class,
@@ -200,12 +200,12 @@ public final Flux<Message> listen() {
 
   @Override
   public Mono<Void> send(Address address, Message message) {
-    return Mono.deferContextual(context -> connections.computeIfAbsent(address, this::connect0))
+    return Mono.deferWithContext(context -> connections.computeIfAbsent(address, this::connect0))
         .flatMap(
             connection ->
-                Mono.deferContextual(context -> sender.send(message))
-                    .contextWrite(context -> context.put(Connection.class, connection)))
-        .contextWrite(
+                Mono.deferWithContext(context -> sender.send(message))
+                    .subscriberContext(context -> context.put(Connection.class, connection)))
+        .subscriberContext(
             context ->
                 context.put(
                     SenderContext.class, new SenderContext(loopResources, this::toByteBuf)));

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/tcp/TcpReceiver.java

@@ -19,7 +19,7 @@ final class TcpReceiver implements Receiver {
 
   @Override
   public Mono<DisposableServer> bind() {
-    return Mono.deferContextual(context -> Mono.just(context.get(ReceiverContext.class)))
+    return Mono.deferWithContext(context -> Mono.just(context.get(ReceiverContext.class)))
         .flatMap(
             context ->
                 newTcpServer(context)

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/tcp/TcpSender.java

@@ -21,14 +21,14 @@ final class TcpSender implements Sender {
 
   @Override
   public Mono<Connection> connect(Address address) {
-    return Mono.deferContextual(context -> Mono.just(context.get(SenderContext.class)))
+    return Mono.deferWithContext(context -> Mono.just(context.get(SenderContext.class)))
         .map(context -> newTcpClient(context, address))
         .flatMap(TcpClient::connect);
   }
 
   @Override
   public Mono<Void> send(Message message) {
-    return Mono.deferContextual(
+    return Mono.deferWithContext(
         context -> {
           Connection connection = context.get(Connection.class);
           SenderContext senderContext = context.get(SenderContext.class);

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/websocket/WebsocketReceiver.java

@@ -24,7 +24,7 @@ final class WebsocketReceiver implements Receiver {
 
   @Override
   public Mono<DisposableServer> bind() {
-    return Mono.deferContextual(context -> Mono.just(context.get(ReceiverContext.class)))
+    return Mono.deferWithContext(context -> Mono.just(context.get(ReceiverContext.class)))
         .flatMap(
             context ->
                 newHttpServer(context)

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/websocket/WebsocketSender.java

@@ -23,14 +23,14 @@ final class WebsocketSender implements Sender {
 
   @Override
   public Mono<Connection> connect(Address address) {
-    return Mono.deferContextual(context -> Mono.just(context.get(SenderContext.class)))
+    return Mono.deferWithContext(context -> Mono.just(context.get(SenderContext.class)))
         .map(context -> newWebsocketSender(context, address))
         .flatMap(sender -> sender.uri("/").connect());
   }
 
   @Override
   public Mono<Void> send(Message message) {
-    return Mono.deferContextual(
+    return Mono.deferWithContext(
         context -> {
           Connection connection = context.get(Connection.class);
           SenderContext senderContext = context.get(SenderContext.class);