VariantStreamSubscription

VariantStreamSubscription

VariantStreamSubscription

Inherited by StreamSubscription< To >, StreamSubscription< From >, StreamSubscription< T >

Public Functions

Name
virtual~VariantStreamSubscription()
virtual intdataTypeId() const =0
virtual QStringdataTypeName() const =0
virtual boolcallIfNextVar(const ProcessVarFn & fn) =0
virtual boolunsubscribe() =0
virtual boolisActive() const =0
virtual boolhasPending() const =0
virtual size_tapproxPendingCount() const =0
virtual intenableNotify() =0
virtual voiddisableNotify() =0
virtual voidsetThrottleItemsPerSec(uint itemsPerSec, bool allowMore =true) =0
virtual voidsuspend() =0
virtual voidresume() =0
virtual voidclearPending() =0
virtual MetaStringMapmetadata() const =0
virtual MetaValuemetadataValue(const QString & key, const MetaValue & defaultValue =nullptr) const =0
virtual MetaValuemetadataValue(CommonMetadataKey key, const MetaValue & defaultValue =nullptr) const =0
virtual voidforcePushNullopt() =0

Public Functions Documentation

function ~VariantStreamSubscription

virtual ~VariantStreamSubscription()

function dataTypeId

virtual int dataTypeId() const =0

Reimplemented by: StreamSubscription::dataTypeId, StreamSubscription::dataTypeId, StreamSubscription::dataTypeId

function dataTypeName

virtual QString dataTypeName() const =0

Reimplemented by: StreamSubscription::dataTypeName, StreamSubscription::dataTypeName, StreamSubscription::dataTypeName

function callIfNextVar

virtual bool callIfNextVar(
    const ProcessVarFn & fn
) =0

Reimplemented by: StreamSubscription::callIfNextVar, StreamSubscription::callIfNextVar, StreamSubscription::callIfNextVar, StreamSubscriptionAdapter::callIfNextVar

function unsubscribe

virtual bool unsubscribe() =0

Reimplemented by: StreamSubscription::unsubscribe, StreamSubscription::unsubscribe, StreamSubscription::unsubscribe, StreamSubscriptionAdapter::unsubscribe

function isActive

virtual bool isActive() const =0

Reimplemented by: StreamSubscription::isActive, StreamSubscription::isActive, StreamSubscription::isActive, StreamSubscriptionAdapter::isActive

function hasPending

virtual bool hasPending() const =0

Reimplemented by: StreamSubscription::hasPending, StreamSubscription::hasPending, StreamSubscription::hasPending, StreamSubscriptionAdapter::hasPending

function approxPendingCount

virtual size_t approxPendingCount() const =0

Reimplemented by: StreamSubscription::approxPendingCount, StreamSubscription::approxPendingCount, StreamSubscription::approxPendingCount, StreamSubscriptionAdapter::approxPendingCount

function enableNotify

virtual int enableNotify() =0

Reimplemented by: StreamSubscription::enableNotify, StreamSubscription::enableNotify, StreamSubscription::enableNotify, StreamSubscriptionAdapter::enableNotify

function disableNotify

virtual void disableNotify() =0

Reimplemented by: StreamSubscription::disableNotify, StreamSubscription::disableNotify, StreamSubscription::disableNotify, StreamSubscriptionAdapter::disableNotify

function setThrottleItemsPerSec

virtual void setThrottleItemsPerSec(
    uint itemsPerSec,
    bool allowMore =true
) =0

Reimplemented by: StreamSubscription::setThrottleItemsPerSec, StreamSubscription::setThrottleItemsPerSec, StreamSubscription::setThrottleItemsPerSec, StreamSubscriptionAdapter::setThrottleItemsPerSec

function suspend

virtual void suspend() =0

Reimplemented by: StreamSubscription::suspend, StreamSubscription::suspend, StreamSubscription::suspend, StreamSubscriptionAdapter::suspend

function resume

virtual void resume() =0

Reimplemented by: StreamSubscription::resume, StreamSubscription::resume, StreamSubscription::resume, StreamSubscriptionAdapter::resume

function clearPending

virtual void clearPending() =0

Reimplemented by: StreamSubscription::clearPending, StreamSubscription::clearPending, StreamSubscription::clearPending, StreamSubscriptionAdapter::clearPending

function metadata

virtual MetaStringMap metadata() const =0

Reimplemented by: StreamSubscription::metadata, StreamSubscription::metadata, StreamSubscription::metadata, StreamSubscriptionAdapter::metadata

function metadataValue

virtual MetaValue metadataValue(
    const QString & key,
    const MetaValue & defaultValue =nullptr
) const =0

Reimplemented by: StreamSubscription::metadataValue, StreamSubscriptionAdapter::metadataValue

function metadataValue

virtual MetaValue metadataValue(
    CommonMetadataKey key,
    const MetaValue & defaultValue =nullptr
) const =0

Reimplemented by: StreamSubscription::metadataValue, StreamSubscriptionAdapter::metadataValue

function forcePushNullopt

virtual void forcePushNullopt() =0

Reimplemented by: StreamSubscription::forcePushNullopt, StreamSubscription::forcePushNullopt, StreamSubscription::forcePushNullopt, StreamSubscriptionAdapter::forcePushNullopt


Updated on 2026-05-20 at 12:42:23 +0000