wreulicke

RxJava: Reactive Extensions for the JVM

RxJava は Java VMにおける Reactive Extensionの実装です。observable 列を使うことによって非同期やイベントベースのプログラムを合成するためのライブラリです。

observerパターンを拡張してデータやイベント列をサポートします。 また、オペレータを追加することで列の合成を宣言的に行うと共に低レベルなスレッド、同期、thread-safety、並列データ構造に関する関心ごとを追いやります。

Getting started

wreulicke

#!/bin/bash

CONTAINER_ID=$1

echo ==============================
echo find jvm process
echo ==============================
PID=`docker exec -t $CONTAINER_ID jps | grep -v Jps | awk --field-separator=" " '{print $1}'`
echo "PID: $PID"

wreulicke

type typ = 
   Int |
   String |
   Bool |
   Func of (typ * typ) |
   Unknown |
   UnitT

type expr =  

wreulicke

package com.github.wreulicke.ast.spoon;

import java.io.IOException;
import java.util.List;
import java.util.Locale;
import java.util.Objects;
import java.util.Set;
import java.util.stream.Collectors;

import lombok.extern.slf4j.Slf4j;

wreulicke

@JsonTypeInfo(use = Id.NAME, property = "type")
@JsonSubTypes({
	@JsonSubTypes.Type(name = Event.HOGE_NAME, value = HogeEvent.class),
	@JsonSubTypes.Type(name = Event.FUGA_NAME, value = FugaEvent.class)
})
public interface Event {
	 
   String HOGE_NAME = "hoge";
   

wreulicke

public class Miso {

    public static void main(String... args){
        int n = Integer.parseInt(args[0]);
        if (n == 1 && n == 2 && n == 3) {
            System.out.println("true");
        } else {
            System.out.println("false");
        }

wreulicke

class 辛い {

	@SpyBean
	HogeService hogeService;

	@Test
	public void testHoge(){

		CyclicBarrier barrier = new CyclicBarrier(2);

wreulicke

package com.github.wreulicke.spring;

import java.util.Collections;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import lombok.extern.slf4j.Slf4j;

import org.springframework.boot.autoconfigure.web.ServerProperties;
import org.springframework.http.HttpStatus;

wreulicke

llvmのインストール

とりあえず今回はお試しで、OSXから

brew install --with-toolchain llvm

wreulicke

package com.github.wreulicke;

import static org.junit.Assert.assertTrue;

import java.lang.reflect.AccessibleObject;
import java.lang.reflect.Constructor;
import java.lang.reflect.Field;
import java.lang.reflect.Member;
import java.lang.reflect.Method;
import java.security.AccessController;