@Internal public final class ConcurrentRequestReplyHandler extends java.lang.Object implements RequestReplyHandler
Constructor and Description |
---|
ConcurrentRequestReplyHandler(java.util.Map<TypeName,StatefulFunctionSpec> functionSpecs) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<Slice> |
handle(Slice requestBytes)
Handles a
Stateful Functions invocation. |
public ConcurrentRequestReplyHandler(java.util.Map<TypeName,StatefulFunctionSpec> functionSpecs)
public java.util.concurrent.CompletableFuture<Slice> handle(Slice requestBytes)
RequestReplyHandler
Stateful Functions
invocation.handle
in interface RequestReplyHandler
requestBytes
- a Slice as received from the StateFun
server.StateFun
server, as the result of this invocation.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.