Method onWriteable

AndroidAsync/src/com/koushikdutta/async/Util.java:83–112

()

            Allocator allocator = new Allocator().setMinAlloc((int)Math.min(2 << 19, max));

            @Override
            public void onWriteable() {
                try {
                    do {
                        if (!pending.hasRemaining()) {
                            ByteBuffer b = allocator.allocate();

                            long toRead = Math.min(max - totalRead, b.capacity());
                            int read = is.read(b.array(), 0, (int)toRead);
                            if (read == -1 || totalRead == max) {
                                cleanup();
                                wrapper.onCompleted(null);
                                return;
                            }
                            allocator.track(read);
                            totalRead += read;
                            b.position(0);
                            b.limit(read);
                            pending.add(b);
                        }
                        
                        ds.write(pending);
                    }
                    while (!pending.hasRemaining());
                }
                catch (Exception e) {
                    cleanup();
                    wrapper.onCompleted(e);
                }
            }
        };
        ds.setWriteableCallback(cb);