AsyncRequestStreams.h

// Copyright (c) Stefano Cristiano
// SPDX-License-Identifier: MIT
#pragma once
#include "../Async/Async.h"
#include "AsyncStreams.h"
 
namespace SC
{
template <typename AsyncRequestType>
struct SC_COMPILER_EXPORT AsyncRequestReadableStream : public AsyncReadableStream
{
    AsyncRequestReadableStream();
 
    void setAutoCloseDescriptor(bool value) { autoCloseDescriptor = value; }
 
    AsyncRequestType request; 
 
  protected:
    struct Internal;
    AsyncEventLoop* eventLoop = nullptr;
 
    AsyncBufferView::ID bufferID;
 
    bool autoCloseDescriptor = false;
 
    virtual Result asyncRead() override;
    virtual Result asyncDestroyReadable() override;
 
    void afterRead(typename AsyncRequestType::Result& result);
    void finalizeReadableDestruction();
 
    static void stopRedableCallback(AsyncResult&);
 
    static Function<void(AsyncResult&)> onStopCallback;
};
 
template <typename AsyncRequestType>
struct SC_COMPILER_EXPORT AsyncRequestWritableStream : public AsyncWritableStream
{
    AsyncRequestWritableStream();
 
    template <typename DescriptorType>
    Result init(AsyncBuffersPool& buffersPool, AsyncEventLoop& eventLoop, const DescriptorType& descriptor);
 
    void setAutoCloseDescriptor(bool value) { autoCloseDescriptor = value; }
 
    AsyncRequestType request; 
 
  protected:
    struct Internal;
    AsyncEventLoop* eventLoop = nullptr;
 
    AsyncBufferView::ID bufferID;
 
    bool autoCloseDescriptor = false;
 
    Function<void(AsyncBufferView::ID)> callback;
 
    virtual Result asyncWrite(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)> cb) override;
    virtual Result asyncDestroyWritable() override;
    virtual bool   canEndWritable() override;
 
    void afterWrite(typename AsyncRequestType::Result& result);
    void finalizeWritableDestruction();
 
    static void stopWritableCallback(AsyncResult&);
 
    static Function<void(AsyncResult&)> onStopCallback;
};
 
struct SC_COMPILER_EXPORT ReadableFileStream : public AsyncRequestReadableStream<AsyncFileRead>
{
    Result init(AsyncBuffersPool& buffersPool, AsyncEventLoop& eventLoop, const FileDescriptor& descriptor);
};
 
struct SC_COMPILER_EXPORT WritableFileStream : public AsyncRequestWritableStream<AsyncFileWrite>
{
    Result init(AsyncBuffersPool& buffersPool, AsyncEventLoop& eventLoop, const FileDescriptor& descriptor);
};
 
struct SC_COMPILER_EXPORT ReadableSocketStream : public AsyncRequestReadableStream<AsyncSocketReceive>
{
    Result init(AsyncBuffersPool& buffersPool, AsyncEventLoop& eventLoop, const SocketDescriptor& descriptor);
};
 
struct SC_COMPILER_EXPORT WritableSocketStream : public AsyncRequestWritableStream<AsyncSocketSend>
{
    Result init(AsyncBuffersPool& buffersPool, AsyncEventLoop& eventLoop, const SocketDescriptor& descriptor);
};
 
} // namespace SC