HttpComponent HttpAsyncClient on Scala

gistfile1.scala

/*
 * ====================================================================
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 * ====================================================================
 *
 * This software consists of voluntary contributions made by many
 * individuals on behalf of the Apache Software Foundation.  For more
 * information on the Apache Software Foundation, please see
 * <http://www.apache.org/>.
 *
 */

package com.github.masahitojp.asynchttpclient

import java.io.IOException
import java.nio.CharBuffer
import java.util.concurrent.Future
import org.apache.http.HttpResponse
import org.apache.http.impl.nio.client.DefaultHttpAsyncClient
import org.apache.http.nio.IOControl
import org.apache.http.nio.client.HttpAsyncClient
import org.apache.http.nio.client.methods.AsyncCharConsumer
import org.apache.http.nio.client.methods.HttpAsyncMethods
import org.apache.http.protocol.HttpContext

object AsyncClientHttpStreaming {
  def run() {
    val httpclient: HttpAsyncClient = new DefaultHttpAsyncClient
    httpclient.start
    try {
      val future: Future[Boolean] = httpclient.execute(HttpAsyncMethods.createGet("http://www.google.co.jp/"), new AsyncClientHttpStreaming.MyResponseConsumer, null)
      val result: Boolean = future.get
      if (result.booleanValue) {
        System.out.println("Request successfully executed")
      }
      else {
        System.out.println("Request failed")
      }
      System.out.println("Shutting down")
    }
    finally {
      httpclient.shutdown
    }
    System.out.println("Done")
  }

  private[asynchttpclient] class MyResponseConsumer extends AsyncCharConsumer[Boolean] {
    protected override def onResponseReceived(response: HttpResponse) {
    }

    protected override def onCharReceived(buf: CharBuffer, ioctrl: IOControl) {
      while (buf.hasRemaining) {
        val chr = buf.get()
        System.out.print(chr.toString.length+"\n")
      }
    }

    protected override def releaseResources {
    }

    protected override def buildResult(context: HttpContext): Boolean = {
      return true
    }
  }

}