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();
 
    template <typename DescriptorType>
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& loop,
                const DescriptorType& descriptor);
 
    Result registerAutoCloseDescriptor(bool value);
 
    AsyncRequestType request; 
 
  protected:
    struct Internal;
 
    Result read();
 
    void afterRead(typename AsyncRequestType::Result& result, AsyncBufferView::ID bufferID);
    void onEndCloseDescriptor();
};
 
template <typename AsyncRequestType>
struct AsyncRequestWritableStream : public AsyncWritableStream
{
    AsyncRequestWritableStream();
 
    template <typename DescriptorType>
    Result init(AsyncBuffersPool& buffersPool, Span<Request> requests, AsyncEventLoop& loop,
                const DescriptorType& descriptor);
 
    Result registerAutoCloseDescriptor(bool value);
 
    AsyncRequestType request; 
 
  protected:
    struct Internal;
 
    Function<void(AsyncBufferView::ID)> callback;
 
    Result write(AsyncBufferView::ID bufferID, Function<void(AsyncBufferView::ID)> cb);
 
    void onEndCloseDescriptor();
};
 
// clang-format off
struct ReadableFileStream : public AsyncRequestReadableStream<AsyncFileRead>{};
struct WritableFileStream : public AsyncRequestWritableStream<AsyncFileWrite>{};
struct ReadableSocketStream : public AsyncRequestReadableStream<AsyncSocketReceive>{};
struct WritableSocketStream : public AsyncRequestWritableStream<AsyncSocketSend>{};
// clang-format on
 
} // namespace SC