csw.messages.framework

Class PubSub.Subscribe<T>

java.lang.Object

csw.messages.framework.PubSub.Subscribe<T>

Type Parameters:

T - represents the type of data that is subscribed

All Implemented Interfaces:

PubSub<T>, PubSub.SubscriberMessage<T>, TMTSerializable, java.io.Serializable, scala.Equals, scala.Product

Enclosing interface:

PubSub<T>

public static class PubSub.Subscribe<T>
extends java.lang.Object
implements PubSub.SubscriberMessage<T>, scala.Product, scala.Serializable

Represents a subscribe action

param: ref the reference of subscriber used to notify to when some data is published

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface csw.messages.framework.PubSub

PubSub.Publish<T>, PubSub.Publish$, PubSub.PublisherMessage<T>, PubSub.Subscribe<T>, PubSub.Subscribe$, PubSub.SubscribeOnly<T>, PubSub.SubscribeOnly$, PubSub.SubscriberMessage<T>, PubSub.Unsubscribe<T>, PubSub.Unsubscribe$

Constructor Summary

Constructors

Constructor and Description
Subscribe(akka.actor.typed.ActorRef<T> ref)

Method Summary

Modifier and Type	Method and Description
akka.actor.typed.ActorRef<T>	ref()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Subscribe

public Subscribe(akka.actor.typed.ActorRef<T> ref)

Method Detail

ref

public akka.actor.typed.ActorRef<T> ref()