Skip to content

Commit fb0ddfb

Browse files
committed
Flush output buffer on each message
1 parent e5e987b commit fb0ddfb

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/backend/libpq/pqcomm.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -259,6 +259,10 @@ static int emscripten_putmessage(char msgtype, const char *s, size_t len) {
259259
appendBinaryStringInfo(&emscripten_buffer, s, len);
260260

261261
emscripten_buffer_busy = false;
262+
263+
// Flush buffer on every message
264+
emscripten_flush();
265+
262266
return 0;
263267

264268
fail:

0 commit comments

Comments
 (0)