|
@@ -344,16 +344,16 @@ setopts(#state{mod = Mod, sock = Sock}, Opts) ->
|
|
|
%% `StartupMessage' and `SSLRequest' packets
|
|
|
-spec send(pg_sock(), iodata()) -> ok | {error, any()}.
|
|
|
send(#state{mod = Mod, sock = Sock}, Data) ->
|
|
|
- do_send(Mod, Sock, epgsql_wire:encode(Data)).
|
|
|
+ do_send(Mod, Sock, epgsql_wire:encode_command(Data)).
|
|
|
|
|
|
-spec send(pg_sock(), byte(), iodata()) -> ok | {error, any()}.
|
|
|
send(#state{mod = Mod, sock = Sock}, Type, Data) ->
|
|
|
- do_send(Mod, Sock, epgsql_wire:encode(Type, Data)).
|
|
|
+ do_send(Mod, Sock, epgsql_wire:encode_command(Type, Data)).
|
|
|
|
|
|
-spec send_multi(pg_sock(), [{byte(), iodata()}]) -> ok | {error, any()}.
|
|
|
send_multi(#state{mod = Mod, sock = Sock}, List) ->
|
|
|
do_send(Mod, Sock, lists:map(fun({Type, Data}) ->
|
|
|
- epgsql_wire:encode(Type, Data)
|
|
|
+ epgsql_wire:encode_command(Type, Data)
|
|
|
end, List)).
|
|
|
|
|
|
do_send(gen_tcp, Sock, Bin) ->
|