에서 일부 EventStream 변화에 따라 http://baconjs.github.io/ var up = $('#up').asEventStream('click');
var down = $('#down').asEventStream('click');
var counter =
// map up to 1, down to -1
up.map(
내가 통해 얻은 나가는 스트림 TCP 연결을 통해 메시지 스트림 코드를 테스트 해요 : 나는 더미 가입자와 결과 Subscriber[ByteString] 대체 어떤 보내는 메시지를 트리거, 내 테스트에서 (IO(StreamTcp) ? StreamTcp.Connect(settings, address))
.mapTo[StreamTcp.OutgoingTcpCo
org.reactivestreams 라이브러리를 사용하여 Java NIO (고성능 용)를 사용하여 대용량 데이터 스트림을 처리하는 몇 가지 코드 예제가 있습니까? 분산 처리를 목표로하고 있으므로 Akka를 사용한 예제가 가장 좋겠지 만, 그 점을 이해할 수 있습니다. 여전히 사건 것으로 보인다 (나는 모든 희망) Source (비 바이너리) 또는 직접 자바
저는 Akka Streams를 가지고 놀았으며 Flow을 생성하고 FlowGraph을 사용하여 연결하는 아이디어를 얻었습니다. Akka의이 부분은 아직 개발 중이므로 일부 작업이 완료되지 않고 다른 일부 비트가 변경 될 수 있지만 "완료"되지 않은 FlowGraph를 만들 수 있습니다. 즉, Sink - 내 코드의 다른 부분에 전달하여 Flow를 추가하고