Interface AgmPeer.StreamHandler
- Enclosing interface:
- AgmPeer
public static interface AgmPeer.StreamHandler
-
Method Summary
-
Method Details
-
data
reactor.core.publisher.Flux<AgmPeer.StreamFlux<Map<String,Object>>> data()- Returns:
- flux with stream flux per branch for non private data
-
accept
reactor.core.publisher.Mono<AgmPeer.StreamFlux<Map<String,Object>>> accept(Map<String,Object> args, String caller)- Parameters:
args- subscription argscaller- subscriber- Returns:
- stream flux with id of the accepted branch and events for private data
-