(pipe *syncSocket, sync syncType, arg any)
| 114 | } |
| 115 | |
| 116 | func writeSyncArg(pipe *syncSocket, sync syncType, arg any) error { |
| 117 | argJSON, err := json.Marshal(arg) |
| 118 | if err != nil { |
| 119 | return fmt.Errorf("writing sync %v: marshal argument failed: %w", sync, err) |
| 120 | } |
| 121 | argJSONMsg := json.RawMessage(argJSON) |
| 122 | return doWriteSync(pipe, syncT{Type: sync, Arg: &argJSONMsg}) |
| 123 | } |
| 124 | |
| 125 | func doReadSync(pipe *syncSocket) (syncT, error) { |
| 126 | var sync syncT |
no test coverage detected
searching dependent graphs…