async_node.h File Reference

Detailed Description

Provides the AsyncNode class for handling asynchronous data streams.

The AsyncNode class is designed to manage asynchronous data streams in the ActionEngine framework. It allows for the reading and writing of data chunks, supports peer binding to enable mirroring of written chunks to a party over the network, and provides methods for consuming data as specific types.

#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <utility>
#include <vector>
#include <absl/base/nullability.h>
#include <absl/base/optimization.h>
#include <absl/base/thread_annotations.h>
#include <absl/container/flat_hash_map.h>
#include <absl/log/check.h>
#include <absl/log/log.h>
#include <absl/status/status.h>
#include <absl/status/statusor.h>
#include <absl/strings/str_cat.h>
#include <absl/time/clock.h>
#include <absl/time/time.h>
#include "actionengine/concurrency/concurrency.h"
#include "actionengine/data/serialization.h"
#include "actionengine/data/types.h"
#include "actionengine/net/stream.h"
#include "actionengine/stores/chunk_store.h"
#include "actionengine/stores/chunk_store_reader.h"
#include "actionengine/stores/chunk_store_writer.h"
#include "actionengine/util/status_macros.h"

Go to the source code of this file.

Classes
class	act::AsyncNode