Interface StreamRpcInterface

pkg/streamclient/streambroker.go:23–26 · view source on GitHub ↗

Source from the content-addressed store, hash-verified

21	}
22
23	type StreamRpcInterface interface {
24	StreamDataAckCommand(data wshrpc.CommandStreamAckData, opts *wshrpc.RpcOpts) error
25	StreamDataCommand(data wshrpc.CommandStreamData, opts *wshrpc.RpcOpts) error
26	}
27
28	type Broker struct {
29	lock sync.Mutex

processSendAckMethod · 0.65

processSendDataMethod · 0.65

RpcApiTypefrontend/app/store/wshclientapi.ts

WshRpcStreamClientAdapterpkg/wshutil/wshstreamadapter.go

mockRpcInterfacepkg/streamclient/streambroker_test.go

WriterBridgecmd/test-streammanager/bridge.go

ReaderBridgecmd/test-streammanager/bridge.go

no outgoing calls

no test coverage detected