Package com.tick42.glue.internal.agm
Class Agm
java.lang.Object
com.tick42.glue.internal.agm.Agm
- All Implemented Interfaces:
Interop
public class Agm extends Object implements Interop
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.tick42.glue.core.interop.Interop
Interop.InstanceSubscriber, Interop.ServerMethodSubscriber -
Constructor Summary
-
Method Summary
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.tick42.glue.core.interop.Interop
getMethods, getMethods, getServers, register, register, registerAsync, stream, stream
-
Constructor Details
-
Agm
-
-
Method Details
-
instance
-
getServers
- Specified by:
getServersin interfaceInterop
-
methods
public CompletionStage<Collection<ServerMethod>> methods(Predicate<ServerMethod> method, Duration timeout) -
methods
-
servers
-
invoke
public CompletionStage<MethodInvocationResult<Map<String,Object>>> invoke(String name, Map<String,Object> arg) -
start
public void start() -
stop
public void stop() -
invoke
public <T, R> CompletionStage<MethodInvocationResult<R>> invoke(Collection<ServerMethod> methods, T arg, InvocationOptions options, ReifiedType<R> returnType) -
stream
public <T, R> CompletionStage<StreamPublisher<R>> stream(ServerMethod method, T arg, ReifiedType<R> eventType)Description copied from interface:InteropInvokes a streaming method with specified arg and returns a future for aStreamPublisher.- Specified by:
streamin interfaceInterop- Type Parameters:
T- type of invocation argumentR- type of streamed data- Parameters:
method- streaming method to be invokedarg- method invocation argumenteventType- type of streamed events- Returns:
- a stage that completes when the stream publisher is resolved
-
stream
public <T, R> CompletionStage<StreamPublisher<R>> stream(String method, T arg, ReifiedType<R> returnType) -
registerAsync
public <T, R> CompletableFuture<MethodRegistration> registerAsync(MethodDefinition definition, MethodInvocationHandler<T,R> handler)- Specified by:
registerAsyncin interfaceInterop
-
register
public <T> CompletionStage<StreamProducer> register(MethodDefinition definition, StreamSubscriptionRequestHandler<T> handler)
-