csw
API
Generated with
csw/csw/csw.event/csw.event.client/csw.event.client.internal.commons/EventSubscriberUtil

EventSubscriberUtil

csw.event.client.internal.commons.EventSubscriberUtil
class EventSubscriberUtil(implicit actorSystem: ActorSystem[_])

Utility class to provided common functionalities to different implementations of EventSubscriber

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def actorCallback(actorRef: ActorRef[Event]): Event => Unit
def pSubscribe(stream: Source[Event, EventSubscription], callback: Event => Unit): EventSubscription
def subscribeAsync(eventSource: Source[Event, EventSubscription], callback: Event => Future[_]): EventSubscription
def subscribeCallback(eventSource: Source[Event, EventSubscription], callback: Event => Unit): EventSubscription
def subscriptionModeStage(every: FiniteDuration, mode: SubscriptionMode): GraphStage[FlowShape[Event, Event]]
Generated with