in_process_wire_stream.h File Reference

In-memory paired WireStream that connects two endpoints without a network. More...

#include <memory>
#include <optional>
#include <string>
#include <utility>
#include <absl/base/nullability.h>
#include <absl/status/status.h>
#include <absl/status/statusor.h>
#include <absl/time/time.h>
#include "a11/concurrency/future.h"
#include "a11/data/types.h"
#include "a11/net/wire_stream.h"

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	a11::net::InProcessWireStream
	A WireStream endpoint wired directly to a peer in the same process. More...

Namespaces
namespace	a11
namespace	a11::net

Detailed Description

In-memory paired WireStream that connects two endpoints without a network.

An InProcessWireStream carries A11 WireMessage traffic between two endpoints living in the same process, with no sockets or serialization on the wire. Pick it when both peers run in one interpreter – for tests, for composing agents locally, and as the internal bridge other transports layer on top of. Like every WireStream it delivers messages without a global ordering guarantee, but it is synchronised on closure: a reader observes every delivered message before the stream completes.