Commit Graph

7 Commits

Author SHA1 Message Date
Artem Bilan
74c8eb40c6 Improve RSocketForwardingFunction
* Use `Mono<RSocket>` for lazy connection on target subscription
returned from the `RSocketForwardingFunction`
* Propagate `retry` into an `RSocketConnector`

Resolves #566
2020-07-29 15:07:48 +02:00
Oleg Zhurakousky
5296badeb2 Split RSocketFuntion
Split RSocketFunction into RSocketForwardingFunction and RSocketListenerFunction to ensure function composition over rsocket works the same way as with simple functions.
2020-07-16 19:26:41 +02:00
Oleg Zhurakousky
cde6535d70 interim 2020-07-16 17:08:55 +02:00
Oleg Zhurakousky
bc7376f2a6 Cleanup 'requestChannel' logic
Add RSocketConnectionUtils to deal with connectivity logic
2020-07-16 15:58:22 +02:00
Oleg Zhurakousky
f725b5aeb8 Add StepVerifier to RSocket tests 2020-07-16 13:35:21 +02:00
Oleg Zhurakousky
76dde19b89 Add initial support for 'requestChannel' intergration for RSocket 2020-07-16 13:35:21 +02:00
Oleg Zhurakousky
c91e2a00e4 Initial Committ of RSocket integration 2020-07-16 13:35:21 +02:00