edgarchan

class PostgreSQLTest extends TestVerticle with VertxScalaHelpers {

  import org.vertx.scala.core._
  import org.vertx.scala.core.eventbus.EventBus._

   ...

}

edgarchan

trait Delegator[T]{
  protected def internal:T
}

trait ReadStream[T <: JReadStream[T]] extends ExceptionSupport[T] { self: Delegator[T] =>

trait WriteStream[T <: JWriteStream[T]] extends ExceptionSupport[T] { self: Delegator[T] =>


class AsyncFile(protected val internal: JAsyncFile) extends Delegator[JAsyncFile] with ReadStream[JAsyncFile] with WriteStream[JAsyncFile]

edgarchan

object  MTypes {

  import org.vertx.scala.core.FunctionConverters._

  trait MessageLike[T]{
    def reply(payload: T, handler: Message[T] => Unit)(implicit jmessage:JMessage[T]):Unit
  }


  object MessageLike{

edgarchan

  @Test
  def pumpFileTest() {
    val fs = vertx.newFileSystem
    val from = fileDir + "/foo.tmp"
    val to = fileDir + "/bar.tmp"
    val content = TestUtils.generateRandomBuffer(10000)

    fs.writeFile(from, content, () => {
      fs.open(from, ares1 => {
        assertEquals(true, Option(ares1.cause).isEmpty)