cyclops javaslang : Reactive Streams Publisher & Subscriber

reactive-streams support

reactive-streams is an api for Stream interoperability. cyclops provides reactive-streams support for JDK Streams, SequenceM and javaslang Streams.

Subscribe to a javaslang Stream

CyclopsSubscriber<Integer> subscriber =SequenceM.subscriber();
		
Stream<Integer> stream = Stream.of(1,2,3);
		
JavaslangReactiveStreamsPublisher.ofSync(stream)
				 .subscribe(subscriber);
		
subscriber.sequenceM()
	 .forEach(System.out::println);

Publish to a javaslang Stream

SequenceM<Integer> publisher =SequenceM.of(1,2,3);
		
JavaslangReactiveStreamsSubscriber<Integer> subscriber = new JavaslangReactiveStreamsSubscriber<>();
publisher.subscribe(subscriber);
		
Stream<Integer> stream = subscriber.getStream();
		
		
stream.forEach(System.out::println);