Package ai.wanaku.core.exchange.v1

Class CodeExecutorClient

java.lang.Object

ai.wanaku.core.exchange.v1.CodeExecutorClient

All Implemented Interfaces:

CodeExecutor, io.quarkus.grpc.MutinyClient<MutinyCodeExecutorGrpc.MutinyCodeExecutorStub>, io.quarkus.grpc.MutinyService

@Generated(value="by Mutiny Grpc generator",
           comments="Source: codeexecution.proto")
public class CodeExecutorClient
extends Object
implements CodeExecutor, io.quarkus.grpc.MutinyClient<MutinyCodeExecutorGrpc.MutinyCodeExecutorStub>

Constructor Summary

Constructors

Constructor	Description
CodeExecutorClient(String name, io.grpc.Channel channel, BiFunction<String,MutinyCodeExecutorGrpc.MutinyCodeExecutorStub,MutinyCodeExecutorGrpc.MutinyCodeExecutorStub> stubConfigurator)

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Multi<CodeExecutionReply>	executeCode(CodeExecutionRequest request)	* Executes code and streams the results back to the client.
MutinyCodeExecutorGrpc.MutinyCodeExecutorStub	getStub()
CodeExecutorClient	newInstanceWithStub(MutinyCodeExecutorGrpc.MutinyCodeExecutorStub stub)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CodeExecutorClient

public CodeExecutorClient(String name,
 io.grpc.Channel channel,
 BiFunction<String,MutinyCodeExecutorGrpc.MutinyCodeExecutorStub,MutinyCodeExecutorGrpc.MutinyCodeExecutorStub> stubConfigurator)

Method Details

newInstanceWithStub

public CodeExecutorClient newInstanceWithStub(MutinyCodeExecutorGrpc.MutinyCodeExecutorStub stub)

Specified by:

newInstanceWithStub in interface io.quarkus.grpc.MutinyClient<MutinyCodeExecutorGrpc.MutinyCodeExecutorStub>

getStub

public MutinyCodeExecutorGrpc.MutinyCodeExecutorStub getStub()

Specified by:

getStub in interface io.quarkus.grpc.MutinyClient<MutinyCodeExecutorGrpc.MutinyCodeExecutorStub>

executeCode

public io.smallrye.mutiny.Multi<CodeExecutionReply> executeCode(CodeExecutionRequest request)

Description copied from interface: CodeExecutor

 *
  Executes code and streams the results back to the client.
  The stream will automatically close when execution completes.
 

Specified by:

executeCode in interface CodeExecutor