Sane C++ Libraries
C++ Platform Abstraction Libraries
Loading...
Searching...
No Matches
SC::AsyncHmacWritableStreamT< T_Hmac > Struct Template Reference

Adapts an incremental message-authentication session to AsyncWritableStream. More...

#include <CryptographyTransformStreams.h>

Inheritance diagram for SC::AsyncHmacWritableStreamT< T_Hmac >:
SC::AsyncWritableStream

Public Member Functions

template<typename T_Argument >
 AsyncHmacWritableStreamT (T_Argument &&argument)
 
- Public Member Functions inherited from SC::AsyncWritableStream
Result init (AsyncBuffersPool &buffersPool)
 Emitted when the underlying resource has been closed.
 
constexpr void setWriteQueue (Span< Request > requests)
 Sets the write queue for this writable stream.
 
size_t getWriteQueueSize () const
 Returns the size of write queue.
 
Result write (AsyncBufferView::ID bufferID, Function< void(AsyncBufferView::ID)> cb={})
 Writes a buffer (that must be allocated by the AsyncBuffersPool passed in AsyncWritableStream) When the buffer it will be actually written, AsyncWritableStream::eventWritten will be raised and its reference count will be decreased.
 
Result write (AsyncBufferView &&bufferView, Function< void(AsyncBufferView::ID)> cb={})
 Push a new buffer view to the queue, registering it with the allocator.
 
void end ()
 Ends the writable stream, waiting for all in-flight and queued writes to finish.
 
void destroy ()
 Forcefully destroys the writable stream before calling end event releasing all resources.
 
AsyncBuffersPoolgetBuffersPool ()
 Obtains the buffers pool to access its data.
 
void finishedWriting (AsyncBufferView::ID bufferID, Function< void(AsyncBufferView::ID)> &&cb, Result res)
 Signals that the given buffer (previously queued by write) has been fully written.
 
void resumeWriting ()
 Resumes writing queued requests for this stream.
 
Result unshift (AsyncBufferView::ID bufferID, Function< void(AsyncBufferView::ID)> &&cb)
 Puts back a buffer at the top of the write queue.
 
void emitError (Result error)
 Signals an async error received.
 
void tryAsync (Result potentialError)
 Will emit error if the passed in Result is false.
 
bool isStillWriting () const
 Returns true if this stream is writing something.
 
bool hasBeenDestroyed () const
 Returns true if the stream has been already destroyed (asynchronously through destroy())
 
void setAutoDestroy (bool value)
 If set to true will automatically call .destroy() when Ended state is reached.
 
bool getAutoDestroy () const
 Returns true if stream will automatically call .destroy() when Ended state is reached.
 

Public Attributes

T_Hmac hmac
 
- Public Attributes inherited from SC::AsyncWritableStream
Event< MaxListeners, Result > eventError
 
Event< MaxListeners > eventDrain
 Emitted when an error occurs.
 
Event< MaxListeners > eventFinish
 Emitted when write queue is empty.
 
Event< MaxListeners > eventClose
 Emitted when no more data can be written.
 

Additional Inherited Members

- Public Types inherited from SC::AsyncWritableStream
using BufferViewID = AsyncBufferView::ID
 
using BuffersPool = AsyncBuffersPool
 
- Static Public Attributes inherited from SC::AsyncWritableStream
static constexpr int MaxListeners = 8
 
- Protected Member Functions inherited from SC::AsyncWritableStream
virtual bool canEndWritable ()
 Allows keeping a writable in ENDING state until it has finished flushing all pending data.
 
void finishedDestroyingWritable ()
 Function that MUST be called by re-implementations of asyncDestroyWritable once they're done.
 
void stop ()
 

Detailed Description

template<typename T_Hmac>
struct SC::AsyncHmacWritableStreamT< T_Hmac >

Adapts an incremental message-authentication session to AsyncWritableStream.

Template Parameters
T_HmacSession type providing add() and reset() with the same span-based shape as Cryptography::Hmac.
Note
Retrieve the completed MAC from hmac inside eventFinish. Automatic stream destruction resets the session immediately after that event returns.

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