Let me welcome you with some Scala code:
object Hello extends App {
println("Hello!")
}And now the same, but with standard Markdown formatting:
object Hello extends App {
Przemek Pokrywka przemek-pokrywka
przemek-pokrywka
/ gist:9315172
Created
March 2, 2014 22:49
How to get None when reduction was not applied and Some(value) when it did in scala.rx
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package frp | |
| import rx._ | |
| import rx.ops._ | |
| object Demo extends App { | |
| case class Val[+T](value: T, reduced: Boolean = false) { | |
| def toOpt = if (reduced) Some(value) else None | |
| } |
przemek-pokrywka
/ StackTraceHelper.scala
Created
September 19, 2013 22:42
Small utility to clean up longish stacktraces. All comments how to make it more generic warmly welcome.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| object StackTraceHelper | |
| { | |
| def retainWithBorder [T] (items: Seq[T], | |
| valuable: (T => Boolean)): Seq[T] = | |
| { | |
| if (items.size < 3) return items | |
| val retained = for | |
| { |
przemek-pokrywka
/ gist:5327732
Last active
December 15, 2015 21:39
— forked from idan/gist:3135754
przemek-pokrywka
/ ReaderMonadDIWhenFunsDependOnVariousThings.scala
Created
January 21, 2013 22:46
Reader Monad dependency injection when each of injected functions depends on something other. The goal is to assess, how good does Reader Monad fit into this context.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| case class Reader[Conf, Res](obtainResult: Conf => Res) { | |
| def map[NewRes](transform: Res => NewRes) = | |
| Reader { | |
| (config: Conf) => | |
| transform(this obtainResult config) | |
| } | |
| def flatMap[NewRes](createReader: Res => Reader[Conf, NewRes]) = | |
| Reader { |
przemek-pokrywka
/ gist:981598
Created
May 19, 2011 20:01
A quick-hack-dirty-fix for Smile hanging threads' problem described at https://github.com/robey/kestrel/issues/26
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| index 2cb9192..42bea4b 100644 | |
| --- a/src/main/scala/net/lag/smile/MemcacheConnection.scala | |
| +++ b/src/main/scala/net/lag/smile/MemcacheConnection.scala | |
| @@ -119,7 +119,7 @@ class MemcacheConnection(val hostname: String, val port: Int, val weight: Int) { | |
| @throws(classOf[MemcacheServerException]) | |
| def store(query: String, key: String, value: Array[Byte], flags: Int, expiry: Int): Boolean = { | |
| - serverActor !? Store(query, key, flags, expiry, value) match { | |
| + serverActor.!?(20 * 1000l, Store(query, key, flags, expiry, value)).getOrElse(Error("Unable to send message to server due to a temporary local problem")) match { | |
| case Timeout => |
przemek-pokrywka
/ Thread hanging (kestrel 1.2)
Created
December 1, 2010 09:15
What does the serverActor do? It never responds to "!?"
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Thread 10: (state = BLOCKED) | |
| - java.lang.Object.wait(long) @bci=0 (Compiled frame; information may be imprecise) | |
| - java.lang.Object.wait() @bci=2, line=485 (Interpreted frame) | |
| - scala.actors.Actor$class.suspendActor(scala.actors.Actor) @bci=21, line=731 (Interpreted frame) | |
| - scala.actors.Actor$class.receive(scala.actors.Actor, scala.PartialFunction) @bci=109, line=431 (Interpreted frame) | |
| - my.innocent.actor.that.simply.wants.to.send.message.via.Kestrel.receive(scala.PartialFunction) @bci=2, line=18 (Interpreted frame) | |
| - scala.actors.Channel.receive(scala.PartialFunction) @bci=16, line=91 (Interpreted frame) | |
| - scala.actors.Actor$class.$bang$qmark(scala.actors.Actor, java.lang.Object) @bci=29, line=599 (Interpreted frame) | |
| - scala.actors.Actor$$anon$1.$bang$qmark(java.lang.Object) @bci=2, line=94 (Interpreted frame) | |
| - net.lag.smile.MemcacheConnection.store(java.lang.String, java.lang.String, byte[], int, int) @bci=19, line=115 (Interpreted frame) |
przemek-pokrywka
/ WrASSE_3_GateActor.scala
Created
November 15, 2010 23:06
Here is how to capture both Gate states: open and closed without using GoF State Pattern. It looks like a thread, but it doesn't block any most of the time. Most of the previously hardcoded things are actor parameters now.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package wrasse3 | |
| import scala.actors.Actor._ | |
| import System.{currentTimeMillis => now} | |
| import actors.{Actor, TIMEOUT} | |
| class GateActor[R](sendRequest: => R, | |
| errorResponse: R, | |
| maxErrors: Int, | |
| closePeriod: Int) extends Actor { |
NewerOlder