Fixed canEncode, doCanDecode conditions

Signed-off-by: dongko <[email protected]>
Signed-off-by: dongKos <[email protected]>

Author: dongKos

r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/codec/ByteArrayInputStreamCodec.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 asyncer.io projects
+ * Copyright 2025 asyncer.io projects
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -52,12 +52,12 @@ public ByteArrayInputStream decode(ByteBuf value, MySqlReadableMetadata metadata
 
     @Override
     protected boolean doCanDecode(MySqlReadableMetadata metadata) {
-        return metadata.getJavaType() == InputStream.class;
+        return metadata.getType().isBinary();
     }
 
     @Override
     public boolean canEncode(Object value) {
-        return value instanceof InputStream;
+        return value instanceof ByteArrayInputStream;
     }
 
     @Override