stealthcode

public static void main(String[] args) {
    TestScheduler scheduler = new TestScheduler();
    Func1<Observer<Observable<? extends Integer>>, PublishSubject<Long>> generator = 
            (Observer<Observable<? extends Integer>> observer) -> {
                PublishSubject<Long> subject = PublishSubject.<Long>create();
                subject.buffer(10, TimeUnit.MILLISECONDS, scheduler)
                    .concatMap((list) -> Observable.from(list))
                    .reduce((total, next) -> next + total)
                    .map((requestBatch) -> get(requestBatch))
                    .subscribe(observer);

stealthcode

import Test.HUnit

data Vim = Vim { cursorRow :: Int, cursorCol :: Int, conent :: String } deriving (Show, Eq)

right :: Vim -> Vim
right v@(Vim y x msg)
  | x > 0 = Vim y (x-1) msg
	| otherwise = v

left :: Vim -> Vim