in_memory library
An in-process coordination transport.
Every node shares one InMemoryBus, which plays the part the network plays for a real transport. Use it to test coordination logic without sockets, native code or timing luck.
Classes
- BusEnvelope
- One published sample or message, as it travels over the bus.
- InMemoryBus
- The shared medium every in-memory node connects to.
- InMemoryCoordinationStream
- Coordination stream over an InMemoryBus.
- InMemoryDataStream
- Data stream over an InMemoryBus.
- InMemoryDiscovery
- IDiscovery over an InMemoryBus.
- InMemoryNetworkStreamFactory
- Builds in-memory streams for a session.
- InMemoryPeerHandle
- A peer found on an InMemoryBus.
- InMemoryTransport
- A transport that carries coordination entirely within one process.
- InMemoryTransportConfig
- Configuration for the in-memory transport.
Mixins
-
InMemoryStreamMixin<
T extends NetworkStreamConfig, M extends IMessage< IMessageType> > - Shared implementation for in-memory coordination and data streams.