K
- the type of keys (which are also used for distribution decisions)REQ
- the type of requestsRES
- the type of responses (wrapped into CompletionStage
to be asynchronous)public interface AsyncBiFunctionService<K,REQ,RES> extends BiFunction<K,REQ,CompletionStage<RES>>, AutoCloseable
BiFunction
that returns an asynchronous CompletionStage
result.Modifier and Type | Interface and Description |
---|---|
static interface |
AsyncBiFunctionService.WithSerdes<K,REQ,RES>
An extension of
AsyncBiFunctionService providing Serde implementations:
AsyncBiFunctionService.WithSerdes.keySerde() , AsyncBiFunctionService.WithSerdes.reqSerde() and AsyncBiFunctionService.WithSerdes.resSerde() . |
Modifier and Type | Method and Description |
---|---|
default Stream<CompletionStage<RES>> |
apply()
Apply to all services, with null key and request - if they can handle it.
|
default Stream<CompletionStage<RES>> |
applyForStore()
Apply to all services for store, with null key and request - if they can handle it.
|
andThen, apply
close
default Stream<CompletionStage<RES>> applyForStore()
default Stream<CompletionStage<RES>> apply()
Copyright © 2020 Red Hat. All rights reserved.