Kevin Meredith kevinmeredith

After scouring the internet and piece-mealing together the correct way to do this, here is a step-by-step, all-in-one-place guide to making logback STFU when running your unit tests.

Here's how to do it

Save the following as logback-test.xml under src/test/resources:

<configuration>
  <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
    <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
      <pattern>%msg%n</pattern>

When creating streams from an asynchronous process, the idiomatic thing is to create a stream from that process at the earliest possible stage, rather than using a queue to invert control after the fact. See the creating streams examples - generally, you just use the Process.eval and Process.repeatEval functions to build a stream by running some asynchronous task repeatedly.

That said, if you have some existing logic that you need to bind to that's already based on callbacks and side effects, you can use the functions in scalaz.stream.async. Here's an example, using a queue to invert control:

import scalaz.stream.async

val (q, src) = async.queue[Int]

// Thread 1

Ever had the need to create a branch in a repo on Github without wanting (or being able) to access a local repo?

With the aid of [the Github API][1] and any online request app this is a piece of cake!

Just follow these steps:

Open an online request app (like apirequest.io, hurl.it pipedream.com, reqbin.com, or webhook.site)
Find the revision you want to branch from. Either on Github itself or by doing a GET request from Hurl: https://api.github.com/repos/<AUTHOR>/<REPO>/git/refs/heads
Copy the revision hash
Do a POST request from Hurl to https://api.github.com/repos/<AUTHOR>/<REPO>/git/refs with the following as the POST body :

	import scala.concurrent.duration._
	import scala.concurrent.ExecutionContext
	import scala.concurrent.Future
	import akka.pattern.after
	import akka.actor.Scheduler

	/**
	* Given an operation that produces a T, returns a Future containing the result of T, unless an exception is thrown,
	* in which case the operation will be retried after _delay_ time, if there are more possible retries, which is configured through
	* the _retries_ parameter. If the operation does not succeed and there is no retries left, the resulting Future will contain the last failure.

	scala> val buf = ListBuffer(1)
	buf: scala.collection.mutable.ListBuffer[Int] = ListBuffer(1)

	scala> val xs = buf.toIterable match { case xs: List[Int] => xs }
	xs: List[Int] = List(1)

	scala> buf ++= 1 to 100
	res11: buf.type = ListBuffer(1, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84, 85, 86, 87, 88, 89, 90, 91, 92, 93, 94, 95, 96, 97, 98, 99, 100)

	scala> xs


	import play.api.libs.json._
	import play.api.libs.functional.syntax._

	sealed trait Parent {
	val typ: String
	}

	case class Foo(blabla: Long, override val typ: String = "foo") extends Parent

	package fizzbuzz

	// This is church encoding of natural numbers
	sealed trait Num {
	def toInt : Int
	override def toString = toInt.toString
	}

	final case object Z extends Num {
	def toInt : Int = 0