ts::ReactiveStream Member List

This is the complete list of members for ts::ReactiveStream, including all inherited members.

activateAsynchronousIO()	ts::ReactiveDevice	protected
activateReadReady()	ts::ReactiveDevice	protected
activateWriteReady()	ts::ReactiveDevice	protected
cancelAndWaitAsynchronousIO(NonBlockingDevice::IOSB &iosb, bool silent)	ts::ReactiveDevice	protected
cancelAsynchronousIO(bool silent)	ts::ReactiveDevice	protected
cancelQueue(IOQueue &inqueue, IOQueue &outqueue)	ts::ReactiveDevice	protected
cancelReadWriteStream(bool silent=false)	ts::ReactiveStream	virtual
createSignalQueuedOperations()	ts::ReactiveBase	protected
deactivateAll(bool silent)	ts::ReactiveDevice	protected
deactivateAsynchronousIO(bool silent)	ts::ReactiveDevice	protected
deactivateQueuedOperations(bool silent)	ts::ReactiveBase	protected
deactivateReadReady(bool silent)	ts::ReactiveDevice	protected
deactivateWriteReady(bool silent)	ts::ReactiveDevice	protected
DEFAULT_RECEIVE_BUFFER_SIZE	ts::ReactiveStream	static
device()	ts::ReactiveDevice	inline
enqueueCompletedIO(const std::shared_ptr< IOSB > &iosb, bool in_reactor)	ts::ReactiveStream	protected
handleAsynchronousIO(Reactor &, EventId, IOSB &, size_t) override	ts::ReactiveStream	protectedvirtual
handleBroadcastEvent(Reactor &reactor, int error_code, const ObjectPtr &user_data)	ts::ReactorHandlerInterface	protectedvirtual
handleProcessTermination(Reactor &reactor, EventId id, int pid)	ts::ReactorHandlerInterface	protectedvirtual
handleReadReady(Reactor &, EventId, int) override	ts::ReactiveStream	protectedvirtual
handleTimer(Reactor &reactor, EventId id)	ts::ReactorHandlerInterface	protectedvirtual
handleUserEvent(Reactor &, EventId) override	ts::ReactiveBase	protectedvirtual
handleWriteReady(Reactor &, EventId, int) override	ts::ReactiveStream	protectedvirtual
hasPendingIO()	ts::ReactiveStream	protectedvirtual
IOQueue typedef	ts::ReactiveDevice	protected
IOSB typedef	ts::ReactiveDevice	protected
IOSet typedef	ts::ReactiveDevice	protected
muteReport(bool mute)	ts::ReporterBase
needsWriteReady()	ts::ReactiveStream	protectedvirtual
processCloseWriteStream(bool silent)	ts::ReactiveStream	protectedvirtual
processQueuedOperations() override	ts::ReactiveStream	protectedvirtual
processReceiveBuffer(ByteBlock &data, ReactiveInputControl &control, ReactiveStreamHandlerInterface *handler, int error_code, const ObjectPtr &user_data)	ts::ReactiveStream	protected
ReactiveBase(Reactor &reactor)	ts::ReactiveBase	explicit
ReactiveDevice(Reactor &reactor, NonBlockingDevice &device)	ts::ReactiveDevice
ReactiveStream(Reactor &reactor, NonBlockingDevice &device, StreamInterface &stream)	ts::ReactiveStream
reactor()	ts::ReactiveBase	inline
removeFromQueue(IOQueue &queue, IOSB *iosb)	ts::ReactiveDevice	protected
report() const override	ts::ReporterBase	virtual
ReporterBase(Report *report)	ts::ReporterBase	inlineexplicit
ReporterBase(ReporterBase *delegate)	ts::ReporterBase	inlineexplicit
setReport(Report *report)	ts::ReporterBase
setReport(ReporterBase *delegate)	ts::ReporterBase
signalQueuedOperations()	ts::ReactiveBase
SilentLevel(bool silent, int default_severity=Severity::Error)	ts::ReporterBase	inlinestatic
startCloseWriteStream(ReactiveStreamHandlerInterface *handler, bool silent, const ObjectPtr &user_data)	ts::ReactiveStream	protectedvirtual
startReadStream(ReactiveStreamHandlerInterface *handler, size_t buffer_size=DEFAULT_RECEIVE_BUFFER_SIZE, const ObjectPtr &user_data=ObjectPtr())	ts::ReactiveStream	virtual
startWriteStream(ReactiveStreamHandlerInterface *handler, const void *data, size_t size, const ObjectPtr &user_data=ObjectPtr())	ts::ReactiveStream	virtual
stream()	ts::ReactiveStream	inline
tryCompletedIO(const std::shared_ptr< IOSB > &iosb)	ts::ReactiveStream	protectedvirtual
uncheckedSignalQueuedOperations()	ts::ReactiveBase	protected
~ReactiveBase() override	ts::ReactiveBase	virtual
~ReactiveDevice() override	ts::ReactiveDevice	virtual
~ReporterBase() override	ts::ReporterBase	virtual