Streaming C++ API
sb::DequeueResult::Interceptor Class Reference

A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples. More...

#include <DequeueResult.hpp>

Public Member Functions

virtual DequeueResult processResult (const DequeueResult &results)
 Take a DequeueResult and modify it. More...
 

Static Public Attributes

static const DequeueResult SUPPRESSED
 SUPPRESSED is a flag used to signify that the results from processResult should be suppressed. More...
 

Detailed Description

A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples.

Member Function Documentation

◆ processResult()

virtual DequeueResult sb::DequeueResult::Interceptor::processResult ( const DequeueResult results)
inlinevirtual

Take a DequeueResult and modify it.

Returns the same object if there are no changes. Returns SUPPRESSED if results should be suppressed. May return a different DequeueResult object.

Member Data Documentation

◆ SUPPRESSED

const DequeueResult sb::DequeueResult::Interceptor::SUPPRESSED
static

SUPPRESSED is a flag used to signify that the results from processResult should be suppressed.


The documentation for this class was generated from the following file: