Method StreamDataCommand

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

(data wshrpc.CommandStreamData, opts *wshrpc.RpcOpts)

Source from the content-addressed store, hash-verified

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 {

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