I hereby claim:
- I am n8han on github.
- I am n8han (https://keybase.io/n8han) on keybase.
- I have a public key whose fingerprint is 43CC D81E 2B53 0E34 9295 31C8 8821 DBD1 7793 FC5F
To claim this, I am signing this object:
public static <A, B> Observable<B> skipMap(Observable<A> source, Func1<A, Observable<B>> action) { | |
return source.first().flatMap(a -> Observable.concat(action.call(a), skipMap(source, action))); | |
} |
I hereby claim:
To claim this, I am signing this object:
object Stream extends Build { | |
lazy val stream = Project("Stream", file("."), settings = Defaults.defaultSettings ++ Seq( | |
scalaVersion := "2.8.1" | |
)) dependsOn (unfiltered) | |
val unfiltered = ProjectRef( file("../../unfiltered"), "unfiltered-websockets") | |
// ... | |
} |
// Instead of this: | |
Porthole..MODULE$.apply(new AbstractFunction1() { public static final long serialVersionUID = 0L; | |
public final String apply(List<Object> paramList) { return Test..MODULE$.test4(paramList); | |
} | |
} | |
// It would be great to have more info in an "AbstractMethod1": |
#!/usr/bin/env python | |
import stream, storage | |
if __name__ == "__main__": | |
# start piping the stream to our storage | |
stream.jsonizer(storage.event_callback) |