OfflineGanttSyncClient class

Implemented types

Constructors

OfflineGanttSyncClient(Future<SqliteCrdt> _dbFuture, [WebSocketGanttSyncClient? _innerClient])

Properties

actorId → String
Returns the ID of the local actor (e.g. 'client-123' or 'user@example.com').
no setteroverride
connectionStateStream → Stream<bool>
no setter
currentHlc → Hlc
Returns the current Hybrid Logical Clock timestamp. Implementations should return the latest known HLC, creating one if necessary.
no setteroverride
hashCode → int
The hash code for this object.
no setterinherited
inboundProgress → Stream<SyncProgress>
Stream of inbound sync progress.
no setteroverride
operationStream → Stream<Operation>
Stream of incoming operations from the server/peers.
no setteroverride
outboundPendingCount → Stream<int>
Stream of pending outbound operations count (e.g. offline queue size).
no setteroverride
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

clearQueue() → Future<void>
dispose() → Future<void>
getInitialState() → Future<List<Operation>>
Fetches the initial state or full state from the server. Returns a list of operations representing the history or current state.
override
getMerkleRoot() → Future<String>
returns the current local Merkle Root hash.
override
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
removeInnerClient() → Future<void>
sendOperation(Operation operation) → Future<void>
Sends an operation to the server/peers.
override
sendOperations(List<Operation> operations) → Future<void>
Sends multiple operations to the server/peers efficiently.
override
setInnerClient(WebSocketGanttSyncClient client) → Future<void>
syncWithMerkle({required MerkleTree localTree}) → Future<void>
Initiates a Merkle-tree based synchronization with a remote peer/server.
override
toString() → String
A string representation of this object.
inherited

Operators

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