joesan

val input = "abccaaaba" // cccaaaba -> ccbaaba -> caaaba -> baaba -> caba -> bba -> bc -> a

val distinctChars = input.distinct.sorted.toList

@tailrec
def reduceString(acc: List[Char], seq: List[Char]): List[Char] = seq match {
  case Nil =>
    if (acc.toSet.size == 1) acc
    else reduceString(List.empty[Char], acc)
  case x :: Nil =>

joesan

find . | grep .git | xargs rm -rf

joesan

import akka.actor.{Actor, ActorRef, Props, Terminated}
import akka.util.ByteString
import ch.jodersky.flow.Serial
import com.typesafe.scalalogging.LazyLogging
import my.samples.deviceManager.DeviceWatcherActor.InitializeSerialPort


class DeviceExplorerActor(serialActorRef: ActorRef)
  extends Actor with LazyLogging  {

joesan

package my.samples.deviceManager

import akka.actor.{Actor, ActorLogging, ActorRef, Kill, Props, Terminated}
import akka.io.IO
import akka.util.ByteString
import ch.jodersky.flow.Serial.Command
import ch.jodersky.flow.{Parity, Serial, SerialSettings}
import my.samples.deviceManager.DeviceExplorerActor.DeviceSerialNumber
import my.samples.deviceManager.DeviceWatcherActor.InitializeSerialPort

joesan

  override def unsafeSubscribeFn(subscriber: Subscriber[String]): Cancelable = {
    val bufferedObs = Observable.fromLinesReader(bufferedReader)
    val obs1 = Observable.interval(1.second)
      .flatMap(elem => {
        val out = new PrintStream(socket.getOutputStream)
        out.print(s"test$elem\n")
        out.flush()
        bufferedObs
      })

joesan

class MyObserver(actorRef: ActorRef, sourceName: String)
  (implicit s: Scheduler) extends Subscriber[String] {

  private[this] def logger = LoggerFactory.getLogger(this.getClass)

  override implicit def scheduler: Scheduler = s

  override def onError(ex: Throwable): Unit = {
    logger.error(s"error happened when processing the stream: error message << ${ex.printStackTrace()} >>")
  }

joesan

object WiFiConnector extends App {

  if (System.getProperty("os.name").contains("Mac"))
    scanMac()
  else
    scanWindows()

  def scanWindows() = {
    val builder = new ProcessBuilder(

joesan

sbt 'set test in Test := {}' clean assembly

joesan

#!/bin/sh
exec scala "$0" "$@"
!#

/***
scalaVersion := "2.11.11"

libraryDependencies ++= Seq(
  "com.typesafe" % "config" % "1.3.1"
)

joesan

find . -name "*.scala" -print | xargs wc -l