Package org.hertsstack.core.service

Class HertsServiceReactiveStreaming<T,K>

java.lang.Object

org.hertsstack.core.service.HertsServiceReactiveStreaming<T,K>

All Implemented Interfaces:

HertsReactiveService, HertsService, ReactiveStreaming

public class HertsServiceReactiveStreaming<T,K>
extends java.lang.Object
implements ReactiveStreaming

Herts reactive streaming service

Constructor Summary

Constructors

Constructor	Description
HertsServiceReactiveStreaming()

Method Summary

Modifier and Type	Method	Description
K	broadcast(java.lang.String clientId)	Broadcast receiver.
org.hertsstack.core.service.HertsBroadCaster	getBroadCaster()
java.lang.String	getClientId()	Get client id for this instance
java.lang.String	getConnection()	Get connections
io.grpc.MethodDescriptor.MethodType	getGrpcMethodType()	Get grpc method
HertsType	getHertsType()	Get implemented herts core type
java.lang.Class<?>	getReceiver()	Get HertsReceiver
java.lang.Class<?>	getService()	Get HertsService.
void	registerReceiver(io.grpc.stub.StreamObserver<java.lang.Object> objectStreamObservers)	Register receiver internal of Client
void	setBroker(org.hertsstack.broker.ReactiveBroker broker)

Methods inherited from class java.lang.Object

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

Constructor Detail

HertsServiceReactiveStreaming

public HertsServiceReactiveStreaming()

Method Detail

getClientId

public java.lang.String getClientId()

Get client id for this instance

Returns:

ClientId

broadcast

public K broadcast(java.lang.String clientId)

Broadcast receiver. Same as generics K type

Parameters:

clientId - ClientId

Returns:

Receiver

registerReceiver

public void registerReceiver(io.grpc.stub.StreamObserver<java.lang.Object> objectStreamObservers)

Description copied from interface: ReactiveStreaming

Register receiver internal of Client

Specified by:

registerReceiver in interface ReactiveStreaming

Parameters:

objectStreamObservers - StreamObserver

getHertsType

public HertsType getHertsType()

Description copied from interface: HertsReactiveService

Get implemented herts core type

Specified by:

getHertsType in interface HertsReactiveService

Specified by:

getHertsType in interface HertsService

Returns:

HertsType

getGrpcMethodType

public io.grpc.MethodDescriptor.MethodType getGrpcMethodType()

Description copied from interface: HertsReactiveService

Get grpc method

Specified by:

getGrpcMethodType in interface HertsReactiveService

Specified by:

getGrpcMethodType in interface HertsService

Returns:

MethodDescriptor.MethodType

getConnection

public java.lang.String getConnection()

Description copied from interface: HertsReactiveService

Get connections

Specified by:

getConnection in interface HertsReactiveService

Specified by:

getConnection in interface HertsService

Returns:

Connection ids

getService

public java.lang.Class<?> getService()

Description copied from interface: HertsReactiveService

Get HertsService.

Specified by:

getService in interface HertsReactiveService

Returns:

HertsService

getReceiver

public java.lang.Class<?> getReceiver()

Description copied from interface: HertsReactiveService

Get HertsReceiver

Specified by:

getReceiver in interface HertsReactiveService

Returns:

HertsReceiver

setBroker

public void setBroker(org.hertsstack.broker.ReactiveBroker broker)

getBroadCaster

public org.hertsstack.core.service.HertsBroadCaster getBroadCaster()