Package com.sportradar.livedata.sdk.proto.common

Class RequestProducerComposite<T extends OutgoingMessage>

java.lang.Object

com.sportradar.livedata.sdk.proto.common.RequestProducerBase<T>

com.sportradar.livedata.sdk.proto.common.RequestProducerComposite<T>

All Implemented Interfaces:

RequestProducer<T>

public class RequestProducerComposite<T extends OutgoingMessage>
extends RequestProducerBase<T>

Represents a composition of multiple RequestProducer instances.

Constructor Summary

Constructors

Constructor	Description
RequestProducerComposite(RequestProducer<T>... producers)	Initializes a new instance of the RequestProducerComposite class.

Method Summary

Modifier and Type	Method	Description
protected void	onStarting()	Invoked by the current RequestProducerBase when it is starting.
protected void	onStopping()	Invoked by the current RequestProducerBase when it is stopping.

Methods inherited from class com.sportradar.livedata.sdk.proto.common.RequestProducerBase

getIsStarted, notifyOnRequestReady, notifyOnRequestReady, setListener, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestProducerComposite

@SafeVarargs
public RequestProducerComposite(RequestProducer<T>... producers)

Initializes a new instance of the RequestProducerComposite class.

Parameters:

producers - the list of the RequestProducer instances to be wrapped in the composite.

Method Detail

onStopping

protected void onStopping()

Invoked by the current RequestProducerBase when it is stopping. Note that the method is called withing critical region, so make sure the execution does not leave the derived class.

Overrides:

onStopping in class RequestProducerBase<T extends OutgoingMessage>

onStarting

protected void onStarting()

Invoked by the current RequestProducerBase when it is starting. Note that the method is called within critical region, so make sure the execution does not leave the derived class.

Overrides:

onStarting in class RequestProducerBase<T extends OutgoingMessage>