@Configuration @ConditionalOnProperty(value="grpc.stub", havingValue="streaming") public static class GrpcProcessorConfiguration.StreamingStubConfiguration extends Object
Constructor and Description |
---|
StreamingStubConfiguration() |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> |
process(reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> request) |
org.springframework.cloud.stream.app.grpc.processor.ReactorProcessorGrpc.ReactorProcessorStub |
processorStub(io.grpc.Channel grpcChannel) |
@Bean public org.springframework.cloud.stream.app.grpc.processor.ReactorProcessorGrpc.ReactorProcessorStub processorStub(io.grpc.Channel grpcChannel)
@StreamListener @Output(value="output") public reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> process(@Input(value="input") reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>> request)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.