Interface StreamSubscriptionRequest<T>
- Type Parameters:
T- type of the subscription request argument
public interface StreamSubscriptionRequest<T>
-
Method Summary
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 Details
-
getArg
T getArg() -
getCaller
Instance getCaller() -
accept
CompletionStage<StreamConsumer<T>> accept() -
acceptOn
-
reject
-