wreulicke wreulicke

RxJava: Reactive Extensions for the JVM

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

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

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

brew install --with-toolchain llvm

	FROM golang AS plugin
	WORKDIR /go/src/github.com/wreulicke/docker-hooks
	COPY . ./
	RUN CGO_ENABLED=0 go build -tags netgo -o main
	RUN mkdir -p /run/docker

	FROM scratch
	COPY --from=plugin /go/src/github.com/wreulicke/docker-hooks /
	COPY --from=plugin /run/docker /run/docker
	ENTRYPOINT ["/main"]

	#!/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"

	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;


	@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";


	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");
	}


	class 辛い {

	@SpyBean
	HogeService hogeService;

	@Test
	public void testHoge(){

	CyclicBarrier barrier = new CyclicBarrier(2);

	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;