public class AsyncBiFunctionServiceGrpcLocalDispatcher extends AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase
Constructor and Description |
---|
AsyncBiFunctionServiceGrpcLocalDispatcher(Collection<LocalService<? extends AsyncBiFunctionService.WithSerdes<?,?,?>>> localAsyncBiFunctionServices) |
Modifier and Type | Method and Description |
---|---|
void |
apply(BiFunctionReq request,
io.grpc.stub.StreamObserver<BiFunctionRes> responseObserver)
CompletionStage<RES> apply(K key, REQ req);
|
bindService
public AsyncBiFunctionServiceGrpcLocalDispatcher(Collection<LocalService<? extends AsyncBiFunctionService.WithSerdes<?,?,?>>> localAsyncBiFunctionServices)
public void apply(BiFunctionReq request, io.grpc.stub.StreamObserver<BiFunctionRes> responseObserver)
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase
CompletionStage<RES> apply(K key, REQ req);
apply
in class AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase
Copyright © 2020 Red Hat. All rights reserved.