diff --git a/src/mysql/read_packet.cr b/src/mysql/read_packet.cr
index 2672ade..c5c0155 100644
--- a/src/mysql/read_packet.cr
+++ b/src/mysql/read_packet.cr
@@ -30,9 +30,15 @@ class MySql::ReadPacket < IO
     raise DB::ConnectionLost.new(@connection)
   end
 
-  def write(slice) : Nil
-    raise "not implemented"
-  end
+  {% if compare_versions(Crystal::VERSION, "0.35.0-0") >= 0 %}
+    def write(slice) : Int64
+      raise "not implemented"
+    end
+  {% else %}
+    def write(slice) : Nil
+      raise "not implemented"
+    end
+  {% end %}
 
   def read_byte!
     read_byte || raise "Unexpected EOF"
diff --git a/src/mysql/write_packet.cr b/src/mysql/write_packet.cr
index fe8bf5b..9f300d1 100644
--- a/src/mysql/write_packet.cr
+++ b/src/mysql/write_packet.cr
@@ -6,11 +6,19 @@ class MySql::WritePacket < IO
     raise "not implemented"
   end
 
-  def write(slice) : Nil
-    @io.write(slice)
-  rescue IO::EOFError
-    raise DB::ConnectionLost.new(@connection)
-  end
+  {% if compare_versions(Crystal::VERSION, "0.35.0-0") >= 0 %}
+    def write(slice) : Int64
+      @io.write(slice)
+    rescue IO::EOFError
+      raise DB::ConnectionLost.new(@connection)
+    end
+  {% else %}
+    def write(slice) : Nil
+      @io.write(slice)
+    rescue IO::EOFError
+      raise DB::ConnectionLost.new(@connection)
+    end
+  {% end %}
 
   def write_lenenc_string(s : String)
     write_lenenc_int(s.bytesize)