diff options
| author | Paul Buetow <paul@buetow.org> | 2023-06-18 19:59:20 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2023-06-18 19:59:20 +0300 |
| commit | 831137abdecfcafeb21fb5f3de45156819f35ed4 (patch) | |
| tree | dfe5f31e781ddde2f5de651965939ea964f6057d /internal/client/tcpclient.go | |
| parent | 5f24c3a2ce346a31820ae27676f18a4d71899a34 (diff) | |
refactor
Diffstat (limited to 'internal/client/tcpclient.go')
| -rw-r--r-- | internal/client/tcpclient.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/client/tcpclient.go b/internal/client/tcpclient.go index 3181fd4..db4334f 100644 --- a/internal/client/tcpclient.go +++ b/internal/client/tcpclient.go @@ -6,7 +6,7 @@ import ( "log" "net" - "codeberg.org/snonux/gorum/internal/tcp" + "codeberg.org/snonux/gorum/internal/iorw" "codeberg.org/snonux/gorum/internal/vote" ) @@ -29,11 +29,11 @@ func tcpClientRun(ctx context.Context, node string, ch <-chan vote.Vote) error { } log.Println("tcpclient: sending", message, "to node", node) - if err := tcp.WriteStr(conn, message); err != nil { + if err := iorw.WriteStr(conn, message); err != nil { return err } - response, err := tcp.ReadStr(conn) + response, err := iorw.ReadStr(conn) if err != nil { return err } |
