Class ContextData
java.lang.Object
com.tick42.glue.internal.gateway.context.ContextData
- All Implemented Interfaces:
ContextSubscription
public class ContextData extends Object implements ContextSubscription
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.tick42.glue.internal.gateway.context.ContextSubscription
ContextSubscription.State -
Method Summary
Modifier and Type Method Description static ContextDataadded(String peer, String name, String id, Function<ContextData,reactor.core.publisher.Mono<?>> subscribe, Function<ContextData,reactor.core.publisher.Mono<?>> unsubscribe)static ContextDatacreate(String peer, String name, Function<ContextData,reactor.core.publisher.Mono<?>> subscribe, Function<ContextData,reactor.core.publisher.Mono<?>> unsubscribe)booleanexists()Optional<String>id()Stringname()Stringpeer()reactor.core.publisher.Flux<Map<String,Object>>publisher()booleanreceived()ContextSubscription.Statestate()
-
Method Details
-
create
public static ContextData create(String peer, String name, Function<ContextData,reactor.core.publisher.Mono<?>> subscribe, Function<ContextData,reactor.core.publisher.Mono<?>> unsubscribe) -
added
public static ContextData added(String peer, String name, String id, Function<ContextData,reactor.core.publisher.Mono<?>> subscribe, Function<ContextData,reactor.core.publisher.Mono<?>> unsubscribe) -
peer
-
name
- Specified by:
namein interfaceContextSubscription
-
id
-
exists
public boolean exists() -
received
public boolean received() -
publisher
- Specified by:
publisherin interfaceContextSubscription
-
state
- Specified by:
statein interfaceContextSubscription
-