spencergibb
d02b6998c3
Migrates to using rsocket-routing-broker
2020-08-24 15:49:31 -04:00
spencergibb
f04e355026
Initial rsocket-broker sample
2020-08-24 15:22:52 -04:00
Oleg Zhurakousky
b6c0578352
Clean up RSocketAutoConfiguration
...
Clean up RSocketAutoConfiguration to better allign with Spring's idioms
Upgraded to Kotlin 1.4.0
2020-08-21 16:03:10 +02:00
Oleg Zhurakousky
99a3be029c
Add support for default function lookup to RSocket
2020-08-05 10:15:29 +02:00
Artem Bilan
8d316f906c
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
buildmaster
83c6236f84
Going back to snapshots
2020-07-20 14:25:39 +00:00
buildmaster
f097ad64fc
Update SNAPSHOT to 3.1.0-M2
2020-07-20 14:23:39 +00:00
Oleg Zhurakousky
4547580d9d
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
638c98cfb7
interim
2020-07-16 17:08:55 +02:00
Oleg Zhurakousky
13aa4700b1
Cleanup 'requestChannel' logic
...
Add RSocketConnectionUtils to deal with connectivity logic
2020-07-16 15:58:22 +02:00
Oleg Zhurakousky
6589164949
Add StepVerifier to RSocket tests
2020-07-16 13:35:21 +02:00
Oleg Zhurakousky
ce6f357117
Add initial support for 'requestChannel' intergration for RSocket
2020-07-16 13:35:21 +02:00
Oleg Zhurakousky
b0398e35df
Initial Committ of RSocket integration
2020-07-16 13:35:21 +02:00
