reactive-grpc,将反应式编程与GRPC Java集成。.zip
需积分: 10 140 浏览量
2019-09-26
09:57:59
上传
评论
收藏 772KB ZIP 举报
reactive-grpc,将反应式编程与GRPC Java集成。.zip （341个子文件） 
gradlew.bat 3KB gradlew.bat 3KB BUILD.bazel 2KB BUILD.bazel 654B BUILD.bazel 532B BUILD.bazel 502B BUILD.bazel 451B BUILD.bazel 418B BUILD.bazel 382B BUILD.bazel 310B BUILD.bazel 236B BUILD.bazel 0B BUILD.bazel 0B BUILD.bazel 0B .bazelignore 12B java_reactive_grpc_library.bzl 5KB repositories.bzl 4KB Program.cs 2KB example-csharp.csproj 558B Backpressure.fxml 3KB .gitignore 149B .gitignore 137B .gitignore 64B .gitignore 18B .gitignore 17B .gitignore 9B .gitignore 7B main.go 2KB build.gradle 2KB build.gradle 2KB build.gradle 704B settings.gradle 43B settings.gradle 15B gradlew 6KB gradlew 6KB
gradle-wrapper.jar 54KB gradle-wrapper.jar 54KB AbstractSubscriberAndProducerTest.java 39KB CancellationPropagationIntegrationTest.java 17KB AbstractSubscriberAndProducer.java 15KB CancellationPropagationIntegrationTest.java 13KB AbstractStreamObserverAndPublisher.java 13KB ReactiveGrpcGenerator.java 11KB StreamObserverAndPublisherTest.java 10KB GrpcRetry.java 10KB ConcurrentRequestIntegrationTest.java 10KB BackpressureIntegrationTest.java 10KB ShareIntegrationTest.java 8KB GrpcRetryTest.java 8KB EndToEndIntegrationTest.java 8KB ChainedCallIntegrationTest.java 8KB ClientCalls.java 7KB ConcurrentRequestIntegrationTest.java 7KB GrpcRetry.java 7KB ClientThreadIntegrationTest.java 7KB ServerCalls.java 7KB ReactiveClientStandardServerInteropTest.java 7KB BackpressureIntegrationTest.java 7KB ReactiveClientStandardServerInteropTest.java 7KB ServerErrorIntegrationTest.java 6KB ContextPropagationIntegrationTest.java 6KB BackpressureChunkingTest.java 6KB StandardClientReactiveServerInteropTest.java 6KB StandardClientReactiveServerInteropTest.java 6KB ServerCalls.java 6KB ServerErrorUpstreamCancellationIntegrationTest.java 6KB EndToEndIntegrationTest.java 6KB ContextPropagationIntegrationTest.java 5KB GrpcRetryTest.java 5KB InprocServerTest.java 5KB ClientCalls.java 5KB ReferenceGRpcBenchmark.java 5KB ClientThreadIntegrationTest.java 5KB ChatClient.java 5KB ReactorGRpcBenchmark.java 5KB UnexpectedServerErrorIntegrationTest.java 5KB RxGRpcBenchmark.java 5KB UnaryZeroMessageResponseIntegrationTest.java 5KB ChainedCallIntegrationTest.java 5KB CancellableStreamObserverTest.java 5KB UnexpectedServerErrorIntegrationTest.java 4KB ServerErrorIntegrationTest.java 4KB ReactorGrpcSubscriberWhiteboxVerificationTest.java 4KB RxGrpcSubscriberWhiteboxVerificationTest.java 4KB BackpressureController.java 4KB ServerErrorUpstreamCancellationIntegrationTest.java 4KB FusionAwareQueueSubscriptionAdapter.java 4KB ChatActivity.java 4KB TestCallStreamObserverProducer.java 4KB TestCallStreamObserverProducer.java 4KB BenchmarkGRpcServerServiceImpl.java 4KB AbstractUnimplementedQueue.java 3KB SwitchOnFirstIntegrationTest.java 3KB UnaryZeroMessageResponseIntegrationTest.java 3KB AsyncRangeCallStreamObserver.java 3KB ReactorChatClient.java 3KB ChatClient.java 3KB ReactorGrpcPublisherManyToOneHalfFusedVerificationTest.java 3KB ReactorGrpcPublisherManyToOneVerificationTest.java 3KB ResumeStreamRxJavaDemo.java 3KB共 341 条
- 1
- 2
- 3
- 4
资源评论
