rsocket-core-1.0.0-RC7-sources.jar

<dependency>
	<groupId>io.rsocket</groupId>
	<artifactId>rsocket-core</artifactId>
	<version>1.0.0-RC7</version>
	<classifier>sources</classifier>
	<type>java-source</type>
</dependency>

io.rsocket:rsocket-core:1.0.0-RC7

META-INF/MANIFEST.MF
io/rsocket/metadata/CompositeMetadata.java
io/rsocket/metadata/RoutingMetadata.java
io/rsocket/metadata/WellKnownMimeType.java
io/rsocket/metadata/TaggingMetadataFlyweight.java
io/rsocket/metadata/TaggingMetadata.java
io/rsocket/metadata/CompositeMetadataFlyweight.java
io/rsocket/metadata/security/AuthMetadataFlyweight.java
io/rsocket/metadata/security/WellKnownAuthType.java
io/rsocket/ResponderRSocket.java
io/rsocket/Payload.java
io/rsocket/frame/RequestFlyweight.java
io/rsocket/frame/RequestFireAndForgetFrameFlyweight.java
io/rsocket/frame/MetadataPushFrameFlyweight.java
io/rsocket/frame/RequestResponseFrameFlyweight.java
io/rsocket/frame/RequestStreamFrameFlyweight.java
io/rsocket/frame/ErrorFrameFlyweight.java
io/rsocket/frame/SetupFrameFlyweight.java
io/rsocket/frame/ExtensionFrameFlyweight.java
io/rsocket/frame/FrameHeaderFlyweight.java
io/rsocket/frame/FrameType.java
io/rsocket/frame/CancelFrameFlyweight.java
io/rsocket/frame/RequestNFrameFlyweight.java
io/rsocket/frame/FrameUtil.java
io/rsocket/frame/ResumeFrameFlyweight.java
io/rsocket/frame/RequestChannelFrameFlyweight.java
io/rsocket/frame/FrameLengthFlyweight.java
io/rsocket/frame/KeepAliveFrameFlyweight.java
io/rsocket/frame/FragmentationFlyweight.java
io/rsocket/frame/ErrorType.java
io/rsocket/frame/VersionFlyweight.java
io/rsocket/frame/ResumeOkFrameFlyweight.java
io/rsocket/frame/decoder/DefaultPayloadDecoder.java
io/rsocket/frame/decoder/PayloadDecoder.java
io/rsocket/frame/decoder/ZeroCopyPayloadDecoder.java
io/rsocket/frame/PayloadFrameFlyweight.java
io/rsocket/frame/LeaseFrameFlyweight.java
io/rsocket/frame/DataAndMetadataFlyweight.java
io/rsocket/buffer/BufferUtil.java
io/rsocket/buffer/Tuple3ByteBuf.java
io/rsocket/buffer/TupleByteBuf.java
io/rsocket/buffer/AbstractTupleByteBuf.java
io/rsocket/buffer/Tuple2ByteBuf.java
io/rsocket/lease/Lease.java
io/rsocket/lease/LeaseImpl.java
io/rsocket/lease/Leases.java
io/rsocket/lease/RequesterLeaseHandler.java
io/rsocket/lease/ResponderLeaseHandler.java
io/rsocket/lease/package-info.java
io/rsocket/lease/MissingLeaseException.java
io/rsocket/lease/LeaseStats.java
io/rsocket/AbstractRSocket.java
io/rsocket/keepalive/KeepAliveFramesAcceptor.java
io/rsocket/keepalive/KeepAliveSupport.java
io/rsocket/keepalive/KeepAliveHandler.java
io/rsocket/ConnectionSetupPayload.java
io/rsocket/RSocket.java
io/rsocket/util/CharByteBufUtil.java
io/rsocket/util/OnceConsumer.java
io/rsocket/util/NumberUtils.java
io/rsocket/util/MonoLifecycleHandler.java
io/rsocket/util/EmptyPayload.java
io/rsocket/util/Function3.java
io/rsocket/util/RSocketProxy.java
io/rsocket/util/DuplexConnectionProxy.java
io/rsocket/util/RecyclerFactory.java
io/rsocket/util/DefaultPayload.java
io/rsocket/util/MultiSubscriberRSocket.java
io/rsocket/util/DisposableUtils.java
io/rsocket/util/ByteBufPayload.java
io/rsocket/util/package-info.java
io/rsocket/util/Clock.java
io/rsocket/fragmentation/FragmentationDuplexConnection.java
io/rsocket/fragmentation/FrameFragmenter.java
io/rsocket/fragmentation/FrameReassembler.java
io/rsocket/fragmentation/ReassemblyDuplexConnection.java
io/rsocket/fragmentation/package-info.java
io/rsocket/DuplexConnection.java
io/rsocket/Availability.java
io/rsocket/Closeable.java
io/rsocket/plugins/SocketAcceptorInterceptor.java
io/rsocket/plugins/DuplexConnectionInterceptor.java
io/rsocket/plugins/InitializingInterceptorRegistry.java
io/rsocket/plugins/InterceptorRegistry.java
io/rsocket/plugins/RSocketInterceptor.java
io/rsocket/RSocketErrorException.java
io/rsocket/core/RSocketServer.java
io/rsocket/core/RSocketResponder.java
io/rsocket/core/ReconnectMono.java
io/rsocket/core/StreamIdSupplier.java
io/rsocket/core/DefaultConnectionSetupPayload.java
io/rsocket/core/RSocketRequester.java
io/rsocket/core/RSocketConnector.java
io/rsocket/core/ServerSetup.java
io/rsocket/core/package-info.java
io/rsocket/core/PayloadValidationUtils.java
io/rsocket/core/Resume.java
io/rsocket/resume/RSocketSession.java
io/rsocket/resume/ServerRSocketSession.java
io/rsocket/resume/ExponentialBackoffResumeStrategy.java
io/rsocket/resume/ClientRSocketSession.java
io/rsocket/resume/ClientResume.java
io/rsocket/resume/PeriodicResumeStrategy.java
io/rsocket/resume/ResumeStateHolder.java
io/rsocket/resume/ResumeStrategy.java
io/rsocket/resume/UpstreamFramesSubscriber.java
io/rsocket/resume/ResumeFramesSubscriber.java
io/rsocket/resume/ResumableFramesStore.java
io/rsocket/resume/InMemoryResumableFramesStore.java
io/rsocket/resume/package-info.java
io/rsocket/resume/RequestListener.java
io/rsocket/resume/ResumableDuplexConnection.java
io/rsocket/resume/SessionManager.java
io/rsocket/resume/ResumeStateException.java
io/rsocket/package-info.java
io/rsocket/RSocketFactory.java
io/rsocket/SocketAcceptor.java
io/rsocket/internal/LimitableRequestPublisher.java
io/rsocket/internal/UnboundedProcessor.java
io/rsocket/internal/Hashing.java
io/rsocket/internal/UnicastMonoEmpty.java
io/rsocket/internal/BitUtil.java
io/rsocket/internal/SwitchTransformFlux.java
io/rsocket/internal/jctools/util/Pow2.java
io/rsocket/internal/jctools/util/RangeUtil.java
io/rsocket/internal/jctools/util/UnsafeAccess.java
io/rsocket/internal/jctools/util/PortableJvmInfo.java
io/rsocket/internal/jctools/util/UnsafeRefArrayAccess.java
io/rsocket/internal/jctools/util/InternalAPI.java
io/rsocket/internal/jctools/queues/LinkedArrayQueueUtil.java
io/rsocket/internal/jctools/queues/BaseLinkedQueue.java
io/rsocket/internal/jctools/queues/BaseMpscLinkedArrayQueue.java
io/rsocket/internal/jctools/queues/IndexedQueueSizeUtil.java
io/rsocket/internal/jctools/queues/CircularArrayOffsetCalculator.java
io/rsocket/internal/jctools/queues/LinkedQueueNode.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)