MCPcopy Create free account
hub / github.com/dotchain/dot / Stream

Function Stream

ops/sync/sync.go:28–47  ·  view source on GitHub ↗

Stream converts an ops Store into a stream. Calling Append() on the Stream is asynchronously appended to the Store and remote changes are also automatically merged into the returned stream. Sync works with a Transformed store. A raw store can be auto transformed via the WithAutoTransform option.

(store ops.Store, opts ...Option)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 6

StreamMethod · 0.92
NonBlockingStreamMethod · 0.92
TestNonblockingSyncFunction · 0.92
TestSyncMultipleInFlightFunction · 0.92
streamFunction · 0.92

Calls 5

DefaultFunction · 0.92
TransformedFunction · 0.92
NewFunction · 0.92
ReliableFunction · 0.85
NonBlockingFunction · 0.85

Tested by 4

TestNonblockingSyncFunction · 0.74
TestSyncMultipleInFlightFunction · 0.74
streamFunction · 0.74