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) |