SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Moves createPending up the chain a bit

Browse Source
This commit is contained in:
Spencer Gibb
2019-09-11 15:47:42 -04:00
parent d7f43b7a72
commit 6bf144551f
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-gateway-rsocket/spring-cloud-gateway-rsocket-broker/src/main/java/org/springframework/cloud/gateway/rsocket/core/GatewayRSocket.java
View File

@@ -144,7 +144,7 @@ public class GatewayRSocket extends AbstractGatewayRSocket {
// put route in exchange for later use
exchange.getAttributes().put(ROUTE_ATTR, route);
return findRSocketOrCreatePending(exchange, route);
});
}).switchIfEmpty(createPending(exchange));
// TODO: deal with connecting to cluster?
}
@@ -165,8 +165,7 @@ public class GatewayRSocket extends AbstractGatewayRSocket {
log.debug("Found RSocket: " + rSocket);
}
return rSocket;
}).log(GatewayRSocket.class.getName() + ".find rsocket", Level.FINEST)
.switchIfEmpty(createPending(exchange));
}).log(GatewayRSocket.class.getName() + ".find rsocket", Level.FINEST);
}
protected Mono<RSocket> createPending(GatewayExchange exchange) {