Merge pull request #105 from akka/wip-format-patriknw

format the code

Author: patriknw

cassandra/.gitignore

@@ -0,0 +1 @@
+/.target/

cassandra/src/main/scala/akka/stream/alpakka/cassandra/GuavaFutures.scala

@@ -20,4 +20,3 @@ private[cassandra] object GuavaFutures {
     }
   }
 }
-

ftp/src/main/scala/akka/stream/alpakka/ftp/impl/FtpBrowserGraphStage.scala

@@ -30,7 +30,8 @@ private[ftp] trait FtpBrowserGraphStage[FtpClient] extends GraphStage[SourceShap
 
       private[this] var buffer: Seq[FtpFile] = Seq.empty[FtpFile]
 
-      setHandler(out, new OutHandler {
+      setHandler(out,
+        new OutHandler {
         def onPull(): Unit = {
           fillBuffer()
           buffer match {

ftp/src/main/scala/akka/stream/alpakka/ftp/impl/FtpIOGraphStage.scala

@@ -43,7 +43,8 @@ private[ftp] trait FtpIOGraphStage[FtpClient]
       private[this] var isOpt: Option[InputStream] = None
       private[this] var readBytesTotal: Long = 0L
 
-      setHandler(out, new OutHandler {
+      setHandler(out,
+        new OutHandler {
         def onPull(): Unit =
           readChunk() match {
             case Some(bs) =>

sqs/src/main/scala/akka/stream/alpakka/sqs/SqsSourceStage.scala

@@ -42,7 +42,8 @@ final class SqsSourceStage(queueUrl: String, settings: SqsSourceSettings, sqsCli
           .withMaxNumberOfMessages(settings.maxBatchSize)
           .withWaitTimeSeconds(settings.longPollingDuration.toSeconds.toInt)
 
-        sqsClient.receiveMessageAsync(request, new AsyncHandler[ReceiveMessageRequest, ReceiveMessageResult] {
+        sqsClient.receiveMessageAsync(request,
+          new AsyncHandler[ReceiveMessageRequest, ReceiveMessageResult] {
           override def onError(e: Exception): Unit =
             failureCallback.invoke(e)
 
@@ -67,7 +68,8 @@ final class SqsSourceStage(queueUrl: String, settings: SqsSourceSettings, sqsCli
         }
       }
 
-      setHandler(out, new OutHandler {
+      setHandler(out,
+        new OutHandler {
         override def onPull(): Unit =
           if (!buffer.isEmpty) {
             if (buffer.size == settings.maxBufferSize - settings.maxBatchSize) {