CRDTSocketClient class abstract

Interface for the CRDT client

Implementers

Constructors

CRDTSocketClient({List<ClientSyncPlugin>? plugins, DocumentCapabilities? capabilities})
Creates a client, with plugins attached to it.

Properties

author → PeerId
The peer ID
no setter
capabilities → DocumentCapabilities
What this build tells the server it can read.
no setter
connectionStatus Stream<ConnectionStatus>
Stream of connection status changes between client and server.
no setter
connectionStatusValue ConnectionStatus
The current connection status. ConnectionStatus.disconnected until the first move.
no setter
document → CRDTDocument
The local CRDT document
no setter
faults Stream<SyncFault>
What the client could not do with something the server sent.
no setter
handshake → HandshakeGate
The handshake of the current connection attempt.
final
hashCode int
The hash code for this object.
no setterinherited
incompatibility SyncIncompatibility?
Why the server refused this build, or null while it has not.
no setter
isUnsupported bool
Whether the server has refused this build.
no setter
lastFault SyncFault?
The last fault, or null while there has been none.
no setter
messages Stream<Message>
Stream of incoming server messages
no setter
plugins List<ClientSyncPlugin>
The client plugins
final
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
sessionId String?
The session ID
no setter
statedCapabilities SyncCapabilities?
capabilities as the peer states them, or null when they claim nothing.
no setter

Methods

closeClientStreams() → void
Ends faults and connectionStatus. Call it from dispose.
connect() Future<bool>
Connect the client to the server
disconnect() Future<void>
Disconnect the client from the server
dispose() → void
Dispose the client
handleErrorMessage(ErrorMessage message) → void
Acts on an ErrorMessage the peer sent, for the codes every client answers the same way.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
refuseBuild({required String code, required String reason}) → void
The server refused this build: stop for good.
refuseServerProtocolMismatch(int serverVersion) bool
Refuses a server that speaks another Protocol.protocolVersion, and says whether it did.
reportSyncFault(SyncFault fault) → void
Reports fault on faults and latches it on lastFault.
requestSync() Future<void>
Request a sync message from the server
sendChange(Change change) Future<void>
Send a Change to the server
sendMessage(Message message) Future<void>
Send a Message to the server
toString() String
A string representation of this object.
inherited
updateConnectionStatus(ConnectionStatus status) → void
Moves the client to status, and publishes it when it is a move.

Operators

operator ==(Object other) bool
The equality operator.
inherited