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 AsyncRequestReadableStream : public AsyncReadableStream
{
    AsyncRequestReadableStream();
 
    void setAutoCloseDescriptor(bool value) { autoCloseDescriptor = value; }
 
    AsyncRequestType request; 
  protected:
    struct Internal;
    AsyncEventLoop* eventLoop = nullptr;
 
    bool autoCloseDescriptor = false;
    bool justUnrefBuffer     = false;
 
    Result read();
 
    void afterRead(typename AsyncRequestType::Result& result, AsyncBufferView::ID bufferID);
    void onCloseStopRequest();
};
 
template <typename AsyncRequestType>
struct AsyncRequestWritableStream : public AsyncWritableStream
{
    AsyncRequestWritableStream();
 
    template <typename DescriptorType>
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& eventLoop,
                const DescriptorType& descriptor);
 
    void setAutoCloseDescriptor(bool value) { autoCloseDescriptor = value; }
 
    AsyncRequestType request; 
 
  protected:
    struct Internal;
    AsyncEventLoop* eventLoop = nullptr;
 
    bool autoCloseDescriptor = false;
    bool justUnrefBuffer     = false;
 
    Function<void(AsyncBufferView::ID)> callback;
 
    Result write(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)> cb);
 
    void onFinishStopRequest();
};
 
struct ReadableFileStream : public AsyncRequestReadableStream<AsyncFileRead>
{
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& eventLoop,
                const FileDescriptor& descriptor);
};
 
struct WritableFileStream : public AsyncRequestWritableStream<AsyncFileWrite>
{
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& eventLoop,
                const FileDescriptor& descriptor);
};
 
struct ReadableSocketStream : public AsyncRequestReadableStream<AsyncSocketReceive>
{
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& eventLoop,
                const SocketDescriptor& descriptor);
};
 
struct WritableSocketStream : public AsyncRequestWritableStream<AsyncSocketSend>
{
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& eventLoop,
                const SocketDescriptor& descriptor);
};
 
} // namespace SC