public class AsyncBiFunctionServiceGrpcClient<K,REQ,RES> extends Object implements AsyncBiFunctionService<K,REQ,RES>
AsyncBiFunctionService.WithSerdes<K,REQ,RES>
Constructor and Description |
---|
AsyncBiFunctionServiceGrpcClient(String serviceName,
io.grpc.Channel channel,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<REQ> reqSerde,
org.apache.kafka.common.serialization.Serde<RES> resSerde) |
Modifier and Type | Method and Description |
---|---|
Stream<CompletionStage<RES>> |
apply()
Apply to all services, with null key and request - if they can handle it.
|
CompletionStage<RES> |
apply(K key,
REQ req) |
Stream<CompletionStage<RES>> |
applyForStore()
Apply to all services for store, with null key and request - if they can handle it.
|
void |
close() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andThen
public void close()
close
in interface AutoCloseable
public CompletionStage<RES> apply(K key, REQ req)
apply
in interface BiFunction<K,REQ,CompletionStage<RES>>
public Stream<CompletionStage<RES>> applyForStore()
AsyncBiFunctionService
applyForStore
in interface AsyncBiFunctionService<K,REQ,RES>
public Stream<CompletionStage<RES>> apply()
AsyncBiFunctionService
apply
in interface AsyncBiFunctionService<K,REQ,RES>
Copyright © 2020 Red Hat. All rights reserved.