hochgi

import dispatch._ ,Defaults._
import com.ning.http.client.Request.EntityWriter
import org.apache.commons.compress.utils.IOUtils
import java.io.{InputStream, OutputStream}
 
implicit def InputStream2EntityWriter(in: InputStream): EntityWriter = new EntityWriter {
  override def writeEntity(out: OutputStream): Unit = {
    IOUtils.copy(in,out)
    in.close
    out.close

hochgi

def solve(board: Seq[Seq[Seq[Int]]]): String = {
  require(board.size == 7 && board.forall(row => row.size == 8 && row.forall(_.size == 3)),"Must have exact dimensions")

  //initialization
  val mat = new Array[Array[(Int,Char)]](8)
  for(i ← 0 to 7){
    mat(i) = new Array[(Int,Char)](8)
    for(j ← 0 to 7) {
      if(i == 0) mat(0)(j) = 0 → '✓'
      else mat(i)(j) = Int.MaxValue → '✓'

hochgi

import akka.actor._
import akka.stream.actor.ActorPublisher
import akka.stream.actor.ActorPublisherMessage.{Cancel, Request}
import akka.stream.scaladsl.Source

import scala.concurrent.{ExecutionContext, Future}
import scala.util.{Failure, Success, Try}

def unfold[S,E](s: S)
               (f: S => Option[(S,E)]): Source[E,ActorRef] =

hochgi

import akka.stream.stage.{OutHandler, GraphStageLogic, GraphStage}
import akka.stream.actor.ActorPublisherMessage.{Cancel, Request}
import akka.stream.scaladsl._
import akka.stream._

import scala.concurrent.{ExecutionContext, Future}
import scala.util.{Failure, Success, Try}

class Unfold[S, E](s: S,f: S => Option[(S, E)]) extends GraphStage[SourceShape[E]] {

hochgi

  object Conf extends ScallopConf(args){

		class BadArgsException(msg: String) extends Exception(msg) {}
		
		val properties = props[String]('D') andThen
		(_.map(_.toLowerCase)) andThen
		(s => s.map { case s if(List("true","t","y","yes").contains(s)) => true 
			          case s if(List("false","f","n","no").contains(s)) => false
			          case s => throw new BadArgsException(s + " is not a boolean value")
			        }

hochgi

object Aggregate {

  private[this] val inc: Any ⇒ Long = _⇒1L

  def apply[In,Out](max: Long, seed: In ⇒ Out)(aggregate: (Out, In) ⇒ Out) =
    AggregateWeighted[In,Out](max, inc, seed)(aggregate)
}

object AggregateWeighted {

hochgi

package hochgi.util.http

import java.io.InputStream

import akka.actor.ActorSystem
import akka.http.scaladsl._
import akka.http.scaladsl.model.HttpHeader.ParsingResult
import akka.http.scaladsl.model._
import akka.http.scaladsl.model.ws._
import akka.stream.stage.{OutHandler, InHandler, GraphStageLogic, GraphStage}

hochgi

import akka.actor.ActorSystem
import akka.stream._
import akka.stream.scaladsl._
import akka.stream.stage._
import com.typesafe.config.ConfigFactory
import org.scalameter._
import scala.concurrent._ ,duration._
import scala.concurrent.ExecutionContext.Implicits.global

object PartitionWithMeter {

hochgi

@prefix foaf:     <http://xmlns.com/foaf/0.1/> .
@prefix dc:       <http://purl.org/dc/terms/> .
@prefix locn:     <http://www.w3.org/ns/locn#> .
@prefix madsrdf:  <http://www.loc.gov/mads/rdf/v1#> .
@prefix geonames: <http://www.geonames.org/ontology#> .
@prefix geo:      <http://www.w3.org/2003/01/geo/wgs84_pos#> .
@prefix xmpl:     <http://ont.example.org/2017/v1.0#> .
@prefix time:     <http://www.w3.org/2006/time#> .
@prefix xsd:      <http://www.w3.org/2001/XMLSchema#> .
@prefix rdfs:     <http://www.w3.org/2000/01/rdf-schema#> .

hochgi

name := s"my-artifact_lib${System.getProperty("cross.build.lib.version")}"

libraryDependencies += "com.some.group" % "some-artifact" % System.getProperty("cross.build.lib.version")

val changeVer = inputKey[Unit]("change system property cross.build.lib.version")

val buildAndPublish = taskKey[Unit]("your custom build task...")

changeVer := {
  import complete.DefaultParsers._