reply to call owner

wg · Sep 24, 2011 · 0be28cc · 0be28cc
1 parent edd1c1f
commit 0be28cc
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/pgsql_sock.erl b/src/pgsql_sock.erl
@@ -141,6 +141,11 @@ send(#state{mod = Mod, sock = Sock}, Data) ->
 send(#state{mod = Mod, sock = Sock}, Type, Data) ->
     Mod:send(Sock, pgsql_wire:encode(Type, Data)).
 
+reply(#state{queue = Q} = State, Message) ->
+    {{value, Pid}, Q2} = queue:out(Q),
+    Pid ! Message,
+    State#state{queue = Q2}.
+
 %% -- backend message handling --
 
 %% AuthenticationOk