Skip to content

Commit b366ec7

Browse files
committed
Fixed TransportImpl
1 parent 691df4f commit b366ec7

File tree

1 file changed

+5
-5
lines changed
  • transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty

1 file changed

+5
-5
lines changed

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -133,11 +133,11 @@ public static Mono<Transport> bind() {
133133
* @return promise for bind operation
134134
*/
135135
public static Mono<Transport> bind(TransportConfig config) {
136-
TransportFactory transportFactory =
137-
Optional.ofNullable(config.transportFactory())
138-
.or(() -> Optional.ofNullable(TransportFactory.INSTANCE))
139-
.orElse(new TcpTransportFactory());
140-
return transportFactory.createTransport(config).start();
136+
return Optional.ofNullable(
137+
Optional.ofNullable(config.transportFactory()).orElse(TransportFactory.INSTANCE))
138+
.orElse(new TcpTransportFactory())
139+
.createTransport(config)
140+
.start();
141141
}
142142

143143
/**

0 commit comments

Comments
 (0)