Interface StreamSubscriptionRequest<T>
-
- Type Parameters:
T- type of the subscription request argument
public interface StreamSubscriptionRequest<T>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description CompletionStage<StreamConsumer<T>>accept()CompletionStage<StreamConsumer<T>>acceptOn(String branch)TgetArg()InstancegetCaller()default CompletionStage<StreamConsumer<T>>reject(String reason)
-
-
-
Method Detail
-
getArg
T getArg()
-
getCaller
Instance getCaller()
-
accept
CompletionStage<StreamConsumer<T>> accept()
-
acceptOn
CompletionStage<StreamConsumer<T>> acceptOn(String branch)
-
reject
default CompletionStage<StreamConsumer<T>> reject(String reason)
-
-