Implement asyncwritebytes on JVM.

Author: donaldh

src/vm/jvm/runtime/org/perl6/nqp/io/AsyncSocketHandle.java

@@ -86,18 +86,30 @@ protected void callback(ThreadContext tc, AsyncTaskInstance task, SixModelObject
         }
     }
 
-    public void writeStr(final ThreadContext tc, final AsyncTaskInstance task, String toWrite) {
+    public void writeStr(ThreadContext tc, AsyncTaskInstance task, String toWrite) {
         try {
             ByteBuffer buffer = enc.encode(CharBuffer.wrap(toWrite));
+            writeByteBuffer(tc, task, buffer);
+        } catch (Throwable e) {
+            throw ExceptionHandling.dieInternal(tc, e);
+        }
+    }
+
+    public void writeBytes(ThreadContext tc, AsyncTaskInstance task, SixModelObject toWrite) {
+        ByteBuffer buffer = Ops.decode8(toWrite, tc);
+        writeByteBuffer(tc, task, buffer);
+    }
 
+    protected void writeByteBuffer(final ThreadContext tc, final AsyncTaskInstance task, ByteBuffer buffer) {
+        try {
             HLLConfig hllConfig = tc.curFrame.codeRef.staticInfo.compUnit.hllConfig;
             final SixModelObject Array = hllConfig.listType;
             final SixModelObject Int = hllConfig.intBoxType;
             final SixModelObject Null = hllConfig.nullValue;
             final SixModelObject Str = hllConfig.strBoxType;
 
             CompletionHandler<Integer, AsyncTaskInstance> handler
-            = new CompletionHandler<Integer, AsyncTaskInstance>() {
+                = new CompletionHandler<Integer, AsyncTaskInstance>() {
 
                 @Override
                 public void completed(Integer bytesWritten, AsyncTaskInstance task) {
@@ -126,10 +138,6 @@ protected void callback(ThreadContext tc, AsyncTaskInstance task, SixModelObject
         }
     }
 
-    public void writeBytes(final ThreadContext tc, final AsyncTaskInstance task, SixModelObject toWrite) {
-
-    }
-
     public void readChars(final ThreadContext tc, final AsyncTaskInstance task) {
         final ByteBuffer readBuffer = ByteBuffer.allocate(32768);
         final CharBuffer decodedBuffer = CharBuffer.allocate(32768);

src/vm/jvm/runtime/org/perl6/nqp/runtime/Ops.java

@@ -3321,7 +3321,7 @@ else if (encoding.equals("utf32")) {
         }
     }
 
-    protected static ByteBuffer decode8(SixModelObject buf, ThreadContext tc) {
+    public static ByteBuffer decode8(SixModelObject buf, ThreadContext tc) {
         ByteBuffer bb;
         if (buf instanceof VMArrayInstance_i8) {
             VMArrayInstance_i8 bufi8 = (VMArrayInstance_i8)buf;