example commit to show shyko what was required

shyiko · Apr 20, 2019 · 88147d7 · 88147d7
1 parent a8e2720
commit 88147d7
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java b/src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java
@@ -63,12 +63,14 @@ public byte[] read() throws IOException {
 
     public void write(Command command, int packetNumber) throws IOException {
         byte[] body = command.toByteArray();
-        outputStream.writeInteger(body.length, 3); // packet length
-        outputStream.writeInteger(packetNumber, 1);
-        outputStream.write(body, 0, body.length);
+        ByteArrayOutputStream wtf = new ByteArrayOutputStream();
+        wtf.writeInteger(body.length, 3); // packet length
+        wtf.writeInteger(packetNumber, 1);
+        wtf.write(body, 0, body.length);
         // though it has no effect in case of default (underlying) output stream (SocketOutputStream),
         // it may be necessary in case of non-default one
-        outputStream.flush();
+        wtf.flush();
+        socket.getOutputStream().write(wtf.toByteArray());
     }
 
     public void write(Command command) throws IOException {