searler

The scodec discriminated.by(tag).typecase(n,message) does not suffice to match all message structures:

1. tag is at start of structure
2. value of tag is not required by the message codec.

The PeekCodec uses the target codec to extract a value, but returns the original BitVector so the tag value can be re-decoded by a subsequent codec.

searler

import scodec.Codec
import scodec.codecs._
import scodec.bits.ByteVector
import scodec.bits.BitVector
import scodec.Attempt
import scodec.DecodeResult

object SerialProtocol {

  sealed trait Parity

searler

 val size: Codec[Int] = new Codec[Int] {
    private val marker = 255
    override def sizeBound = uint(8).sizeBound | uint(32).sizeBound
    override def encode(value: Int) = if (value < marker)
      uint(8).encode(value)
    else
      (uint(8) ~ uint(32)).encode(marker ~ value)
    override def decode(bits: BitVector) = {
      uint(8).decode(bits) match {
        case Attempt.Successful(DecodeResult(value, remainder)) if value == marker => int(32).decode(remainder)

searler

def text = Action(parse.json) { request =>
    val caret = (request.body \ "caret").as[Int]
    val text = (request.body \ "text").as[String]
    val trimmed = text.filterNot(_ == 'a')

    Ok(Json.obj("caret" -> (caret-(text.length-trimmed.length)), "text" -> trimmed))
}

searler

var Editor = React.createClass({
    	getInitialState: function() {
    		return {value: 'Hello!'};
    	},
    	handleChange: function(event) {
    		var caretPos = this.getDOMNode().selectionStart;
    		var msg = {text:event.target.value,caret:caretPos};
    		$.ajax({url: "/text", type: "POST",
    			data: JSON.stringify(msg),
                contentType:"application/json; charset=utf-8", dataType:"json",

searler

public class CamelBlocking {

   public static void main(String[] args) throws InterruptedException {
      CamelContext camelContext = new DefaultCamelContext();
      ReactiveCamel rx = new ReactiveCamel(camelContext);
      Observable<String> observable = rx.toObservable(
            "stream:in?scanStream=true", String.class);
      observable.toBlockingObservable().forEach(new Action1<String>() {
         @Override
         public void call(String m) {

searler

public class Recursive {

   public static void main(String[] args) throws InterruptedException {

      final Scheduler scheduler = Schedulers.newThread();

      Observable<Character> obs = Observable
            .create(new OnSubscribeFunc<Character>() {
               @Override
               public Subscription onSubscribe(

searler

package baudot;

import java.util.Arrays;

import rx.Observable;
import rx.Observable.OnSubscribeFunc;
import rx.Observer;
import rx.Subscription;
import rx.util.functions.Func1;

searler

// create attribute to record comment
val comment = Attribute(new Namespace("meta") / "comment", SchemaType.string, Cardinality.one)
Datomic.transact(comment)

// data from txReportQueue
val txr:datomisca.TxReport = ...

// assert "sent email" on all the transactions
Datomic.transact(txr.txData.map{case DDatom(_,_,_,tx,_) => tx}.distinct.
  map{id => SchemaEntity.add(FinalId(id))(Props() + (comment-> "sent email"))})

searler

import datomisca._
import scala.concurrent._
import scala.concurrent.duration.Duration
import datomisca.executioncontext.ExecutionContextHelper._

object TxReportQuery {

  object PersonSchema {

    object ns {