arturaz

### utils/rx/Observable.cs ###
?using System;
using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using utils.functional;

namespace utils.rx {
  public interface IObservable<T> {
    ISubscription subscribe(Action<T> onChange);

arturaz

        val myRank = (session: Session) => {
          val mine = Ratings.filter(_.userId === user.id).map(mapper).
            first()(session)
          Ratings.filter { mapper(_) > mine }.map(_.length + 1)
        }

arturaz

      packageConfiguration in packageBin in Compile <<= (
        packageConfiguration in packageBin in Compile, baseDirectory
      ) map { (c, b) =>
        val jar = b / "Plugins" / "Android" / "xclient.jar"
        new Package.Configuration(c.sources, jar, c.options)
      }

arturaz

package com.tinylabproductions.quazibuild.server.messaging

import com.tinylabproductions.quazibuild.{messaging => m}
import com.tinylabproductions.quazibuild.messaging.Messages.S2C
import com.google.protobuf.GeneratedMessage
import com.tinylabproductions.quazibuild.messaging.LiveGame._
import com.tinylabproductions.quazibuild.server.model.{StoredResource, Resource}
import com.tinylabproductions.quazibuild.messaging.Base.User
import com.tinylabproductions.quazibuild.server.actor.live_game.model.Ship
import implicits._

arturaz

  public IEnumerator<Tuple2<T, Direction>> GetEnumerator() {
    if (top != null) 
      yield return new Tuple2<T, Direction>(top, Direction.Top);
    if (right != null) 
      yield return new Tuple2<T, Direction>(right, Direction.Right);
    if (down != null) 
      yield return new Tuple2<T, Direction>(down, Direction.Down);
    if (left != null)
      yield return new Tuple2<T, Direction>(left, Direction.Left);
  }

arturaz

package com.tinylabproductions.quazibuild.server.actor.connection

import akka.actor.{Props, ActorRef, Actor}
import akka.io.Tcp._
import java.net.InetSocketAddress
import akka.util.ByteString
import com.tinylabproductions.quazibuild.server.messaging._
import com.tinylabproductions.quazibuild.server.actor.Logging
import com.tinylabproductions.quazibuild.messaging.Messages.{S2C, C2S}
import akka.io._

arturaz

object ChiShapeGenerator extends ChiShapeGenerator {
  trait JavaConvertible[From, To] { def asJava(obj: From): To }
  object JavaConvertible {
    def apply[A, B](obj: A) = implicitly[JavaConvertible[A, B]].asJava(obj)

    implicit object HoleParamsJC extends JavaConvertible[HoleParams, HP] {
      def asJava(obj: HoleParams) = new HP(obj.holeEdgeLengthThreshold)
    }

    implicit object SmoothHoleParamsJC

arturaz

  def extractEither[
    Key, TLeft, TRight, M[_] <: TraversableOnce[_]
  ]
  (monad: M[(Key, Either[TLeft, TRight])])
  (implicit cbf: CanBuildFrom[
    M[(Key, Either[TLeft, TRight])],
    (Key, TRight),
    M[(Key, TRight)]
  ]): Either[TLeft, M[(Key, TRight)]] = {
    val builder = cbf(monad)

arturaz

    private static LeaderboardName getLeaderboardName(
      Kind kind, LeaderboardKind lbKind
    ) {
      return new LeaderboardName(
        kind.match().returning<string>
          .when<Kind.Global>(_ => string.Format(
            "lb_{0}", leaderboardKindToString(lbKind)
          ))
          .when<Kind.World>(kw => string.Format(
            "lb_w{0}_{1}", kw.world, leaderboardKindToString(lbKind)

arturaz

using System;

namespace Utils.Match {
  public interface IMatcher<in Base, Return> where Base : class {
    IMatcher<Base, Return> when<T>(Func<T, Return> onMatch) 
    where T : class, Base;

    Return get();
    Return getOrElse(Func<Return> elseFunc);
  }