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;
 
    bool autoCloseDescriptor = false;
    bool justUnrefBuffer     = false;
 
    Result read();
 
    void afterRead(typename AsyncRequestType::Result& result, AsyncBufferView::ID bufferID);
    void onCloseStopRequest();
};
 
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;
 
    bool autoCloseDescriptor = false;
    bool justUnrefBuffer     = false;
 
    Function<void(AsyncBufferView::ID)> callback;
 
    Result write(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)> cb);
 
    void onFinishStopRequest();
};
 
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