Skip to content

Instantly share code, notes, and snippets.

package main;
import rx.Observable;
import rx.schedulers.Schedulers;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
import java.util.stream.IntStream;
public class BackpressureDemo {
package io.strati.functional;
import java.util.NoSuchElementException;
import java.util.function.Consumer;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.function.Supplier;
import java.util.stream.Stream;
/**
@flatmap13
flatmap13 / LookAndSay.scala
Created December 3, 2014 20:52
reactive look-and-say sequence w/ RxScala
import rx.lang.scala.Observable
import rx.lang.scala.subjects.BehaviorSubject
object LookAndSay {
def main(args: Array[String]) {
val pipe = BehaviorSubject(Observable.just('1'))
pipe.map(next).foreach(x => {
x.doOnCompleted(println()).foreach(print(_))
pipe.onNext(x)
@flatmap13
flatmap13 / error.c
Created January 13, 2013 10:51
Small command line application to translate error numbers to readable messages. You can supply multiple error numbers via command line arguments. If zero arguments are supplied, the app asks for an error number interactively.
#include <stdio.h>
#include <string.h>
void print_error(int);
int main(int argc, char *argv[])
{
int err_num;
if(argc > 1) {
while(--argc > 0 && ++argv) {