run

open override fun run(    handlerContext: HandlerContext,     requestSerde: Serde<REQ>,     responseSerde: Serde<RES>,     onClosedInvocationStreamHook: AtomicReference<Runnable>): CompletableFuture<Slice>