MCPcopy
hub / github.com/NVIDIA/aistore / Fin

Method Fin

transport/api.go:172–175  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

170}
171
172func (s *Stream) Fin() {
173 _ = s.Send(&Obj{Hdr: ObjHdr{Opcode: opcFin}})
174 s.wg.Wait()
175}
176
177////////////////////
178// message stream //

Callers 9

Example_headersFunction · 0.45
Example_objFunction · 0.45
Test_MultipleNetworksFunction · 0.45
Test_OnSendCallbackFunction · 0.45
Test_ObjAttrsFunction · 0.45
Test_CompressedOneFunction · 0.45
Test_DryRunFunction · 0.45
streamWriteUntilFunction · 0.45
applyMethod · 0.45

Calls 2

SendMethod · 0.95
WaitMethod · 0.65

Tested by 8

Example_headersFunction · 0.36
Example_objFunction · 0.36
Test_MultipleNetworksFunction · 0.36
Test_OnSendCallbackFunction · 0.36
Test_ObjAttrsFunction · 0.36
Test_CompressedOneFunction · 0.36
Test_DryRunFunction · 0.36
streamWriteUntilFunction · 0.36