Package com.hcl.domino.keep.eventbus

Interface Summary

Interface	Description
EventBusRequestObservable<T>	Interface for backpressure sensitive operation of Eventbus to HTTP/EventArch/Others transmission
EventBusResponseSubscriber<T>	Interface describing all methods an EvenBusResponseSubscriber needs and extends: - ObservableEmitter - Serializable - KeepSubscriberInfo
KeepSubscriberInfo	Extended information a keep subscriber is carrying forward like APIName and User

Class Summary

Class	Description
AbstractEventBusResponseSubscriber<T>	Observer that starts sending back data retrieved from a subscription onto the eventbus
DeliveryOpts	The delivery options we use for streaming callback
EventBusBufferResponseSubscriber	Subscriber to wrap EventBus Buffer messages in an Observer/subscriber pattern
EventBusJsonResponseSubscriber
EventBusTracker
KeepEventBusRequestObservable<T>	Handles the communication from an Handler to and from the eventbus Abstracts the creation of the temporary listener address and processing of replies and errors
KeepSubscriber	Shortcut object for ObservableEmitter to handle the methods we usually don’t implement
ResponseSubscriberOutputStream	OutputStream that sends data received over the Eventbus in reasonable chunks of bytes.