Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
Index your code
hub
/
github.com/nutsdb/nutsdb
/ Wait
Method
Wait
value.go:42–47 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
40
}
41
42
func
(req *request) Wait() error {
43
req.Wg.Wait()
44
err := req.Err
45
req.DecrRef()
// DecrRef after writing to DB.
46
return
err
47
}
Callers
15
TestTransactionManager_ConcurrentRegisterUnregister
Function · 0.80
TestWatchManager_SubscribeAndSendMessage
Function · 0.80
TestWatchManager_SubscribeAndUnsubscribe
Function · 0.80
TestWatchManager_StartDistributor
Function · 0.80
TestWriteBatch_SetMaxPendingTxns
Function · 0.80
TestWriteBatchCommit_UnregistersOnBeginTxFailure
Function · 0.80
TestWriteBatch_ConcurrentWithUpdate
Function · 0.80
waitForGoroutines
Method · 0.80
TestWatcher_Run
Function · 0.80
TestWatcher_WaitReady
Function · 0.80
TestWatcher_ThreadSafety
Function · 0.80
TestWatcher_Integration
Function · 0.80
Calls
1
DecrRef
Method · 0.95
Tested by
15
TestTransactionManager_ConcurrentRegisterUnregister
Function · 0.64
TestWatchManager_SubscribeAndSendMessage
Function · 0.64
TestWatchManager_SubscribeAndUnsubscribe
Function · 0.64
TestWatchManager_StartDistributor
Function · 0.64
TestWriteBatch_SetMaxPendingTxns
Function · 0.64
TestWriteBatchCommit_UnregistersOnBeginTxFailure
Function · 0.64
TestWriteBatch_ConcurrentWithUpdate
Function · 0.64
TestWatcher_Run
Function · 0.64
TestWatcher_WaitReady
Function · 0.64
TestWatcher_ThreadSafety
Function · 0.64
TestWatcher_Integration
Function · 0.64
TestMergeWorker_RejectConcurrentMerge
Function · 0.64