Rossen Stoyanchev
9fe1feea9a
Provide access to underlying RSocketClient
...
The recently introduced support for RSocketClient in commit
7c98251142
did not expose the underlying
client in order to avoid a hard dependency on RSocket 1.1 for the time
being. However such access appears to be necessary, e.g. for Spring
Integration, where the connection needs to be established (warmed up)
ahead of actual requests.
See gh-25332
5 years ago
Rossen Stoyanchev
f9ba58eab9
Match subscriptions to remove by id
...
Commit 524ca1a676
unintentionally changed
how subscriptions to be removed are matched. This commit restores that.
See gh-25298
5 years ago
XenoAmess
e71f702bb9
Use `static private` instead of `private static` for method declarations
...
Closes gh-25452
5 years ago
Rossen Stoyanchev
b451379c2f
Update eviction queue before size
...
See gh-25298
5 years ago
Rossen Stoyanchev
44f1f94f97
Polishing contribution
...
Renaming, trimming of method parameters, minor refactoring of helper
methods, comments, etc. Completely functionally neutral.
See gh-25298
5 years ago
Tomas Drabek
524ca1a676
DefaultSubscriptionRegistry: Reduced thread contention
...
* DestinationCache is now synchronized on multiple 'destination' locks
(previously a single shared lock)
* DestinationCache keeps destinations without any subscriptions
(previously such destinations were recomputed over and over)
* SessionSubscriptionRegistry is now a
'sessionId -> subscriptionId -> (destination,selector)' map
for faster lookups
(previously 'sessionId -> destination -> set of (subscriptionId,selector)')
closes gh-24395
5 years ago
Rossen Stoyanchev
7c98251142
Support for making requests via RSocketClient
...
Closes gh-25332
5 years ago
Rossen Stoyanchev
b2a4d1c5b1
Avoid re-creating connect Mono<RSocket>
...
Closes gh-25330
5 years ago
Rossen Stoyanchev
b16f6fa456
Shared static instance of DefaultDataBufferFactory
5 years ago
Sam Brannen
b33d2fe683
Clean up warnings in Gradle build, polishing, etc.
5 years ago
Rossen Stoyanchev
22bf62def1
Replace remaining use of deprecated Processors in tests
...
See gh-25085
5 years ago
Rossen Stoyanchev
734f4a4706
Replace of ReplayProcessor in RSocket tests
...
See gh-25085
5 years ago
Rossen Stoyanchev
7cf1ccc415
Use MonoProcessor instead of FluxIdentityProcessor
...
We just need to signal completion when close() is called. MonoProcessor
should suffice and we can avoid a hard dependency on Reactor 3.4.
See gh-25085
5 years ago
Sam Brannen
ab0e651547
Polish SerializationTestUtils, clean up warnings, etc.
5 years ago
Brian Clozel
7391f9b392
Fix Reactor Core DirectProcessor deprecation
...
As of reactor/reactor-core#2188 , `DirectProcessor` variants are
deprecated. This commit replaces them with the new
`FluxIdentityProcessor` variant.
See gh-25085
5 years ago
Sébastien Deleuze
6b355df903
Revert "Upgrade to Kotlin 1.4 M2"
...
This reverts commit 2a74eff10f
.
Some regressions require to wait at least Kotlin 1.4 M3.
5 years ago
Сергей Цыпанов
7949937655
Remove redundant assignment of default values to volatile fields
5 years ago
Sébastien Deleuze
2a74eff10f
Upgrade to Kotlin 1.4 M2
...
- The compiler is configured to retain compatibility with Kotlin 1.3.
- Explicit API mode is not yet enabled but could be in the future.
- A workaround for Gradle build is required for now, see
https://youtrack.jetbrains.com/issue/KT-39610 for more details.
- Some exceptions thrown by Kotlin have changed to NullPointerException,
see https://youtrack.jetbrains.com/issue/KT-22275 for more details.
Closes gh-24171
5 years ago
Rossen Stoyanchev
1d0fe1223d
Fix checkstyle violation
5 years ago
Rossen Stoyanchev
b48ddef4c6
Upgrade to RSocket 1.0.1
5 years ago
Rossen Stoyanchev
6d6269f1ee
Switch to Reactor 2020.0.0 snapshots
...
A switch to RSocket 1.0.1 snapshots is also required to pick up a
for froward compatibility with Reactor Netty 1.0.
See gh-25085
5 years ago
Juergen Hoeller
c35b21b49f
Consistent not-null assertions for configured interceptors
...
Closes gh-25088
5 years ago
Rossen Stoyanchev
b1224835be
Add metadataPush support to RSocketRequester
...
Closes gh-24322
5 years ago
Rossen Stoyanchev
ef27bc4b82
Upgrade to RSocket 1.0.0
...
Closes gh-25053
5 years ago
Rossen Stoyanchev
71d384f1f8
Upgrade to RSocket 1.0.0
...
Closes gh-25053
5 years ago
Rossen Stoyanchev
7f59381c7d
Add support for RxJava 3
...
Closes gh-24170
5 years ago
Rossen Stoyanchev
2002a1689a
Adapt test to changes in RSocket Java
...
See gh-24934
5 years ago
Sam Brannen
5eba1ae73c
Avoid deprecation warning in DefaultRSocketRequesterBuilderTests
5 years ago
Rossen Stoyanchev
1904e9b7e7
Disable failing test temporarily
5 years ago
Rossen Stoyanchev
ed8c61a852
Upgrade to RSocket 1.0 RC7 snapshots
5 years ago
Sébastien Deleuze
3c354a9b18
Avoid using Mockito argument matcher in Mockk test
5 years ago
陈其苗
13970ae528
Use autoboxing instead of explicit wrapping in tests
...
Closes gh-24801
5 years ago
Rossen Stoyanchev
95ef9c25c2
Reduce byte[] allocations in StompEncoder
...
Closes gh-24694
5 years ago
Sam Brannen
e26764d249
Remove duplicate words in documentation and polish Javadoc
5 years ago
Sam Brannen
9e30620ac2
Polish contribution
...
See gh-24805
5 years ago
Сергей Цыпанов
e63d1cf12d
Improve usage of ByteArrayOutputStream/ByteArrayInputStream
...
Closes gh-24805
5 years ago
Qimiao Chen
7c831d2ef4
Replace anonymous inner classes with lambdas in tests
...
Closes gh-24808
5 years ago
Rossen Stoyanchev
3175f0771e
Remove dumpString from DataBufferTestUtils
...
See gh-24786
5 years ago
Sam Brannen
6222efc54b
Polish contribution
...
See gh-24785
5 years ago
Сергей Цыпанов
65aa2d03f0
Simplify conversion of ByteArrayOutputStream to String
...
Closes gh-24785
5 years ago
Qimiao Chen
09b36380cd
Fix typos in source files
...
Closes gh-24746
5 years ago
Rossen Stoyanchev
7efb62091d
MessagingRSocket correctly handles unconsumed input
...
Closes gh-24741
5 years ago
Rossen Stoyanchev
5b27df772a
Suppress deprecation warning
...
See gh-24725
5 years ago
Sam Brannen
a8feb792da
Fix broken Javadoc links
5 years ago
Rossen Stoyanchev
4aedf2ea13
MetadataEncoder expands vars correctly
...
Closes gh-24656
5 years ago
ZhangT
c5fb7b9fb7
Simplify some redundant code
...
Closes gh-24586
Co-authored-by: Sam Brannen <sbrannen@pivotal.io>
5 years ago
Hyunjin Choi
ede2a1d4b2
Remove unnecessary semicolon in some enum classes
5 years ago
Rossen Stoyanchev
28a95e89f3
Upgrade to Dysprosium SR5 snapshots
...
See gh-24355
5 years ago
Rossen Stoyanchev
3c0c0c0597
Fix issue with new line handling in StompDecoder
...
Closes gh-23713
5 years ago
Sam Brannen
94f8ef08e2
Move common TestPrincipal to spring-core test fixtures
...
See gh-23550
5 years ago