| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent ec617b2 commit eeb850d
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -132,58 +132,4 @@ public void onNext(Object o) { | |||
| 132 | 132 | } | |
| 133 | 133 | }); | |
| 134 | 134 | } | |
| 135 | - | ||
| 136 | - /* | ||
| 137 | - | ||
| 138 | - // Get Observable of List<Contributor> | ||
| 139 | - // Then from each contributor object in that List | ||
| 140 | - // print out the contributions and name | ||
| 141 | - | ||
| 142 | - github.contributors("netflix", "rxjava") | ||
| 143 | - .lift(flattenList()) | ||
| 144 | - .forEach(c -> println(c.contributions + '\t' + c.login)); | ||
| 145 | - | ||
| 146 | - | ||
| 147 | - 1483 benjchritensen | ||
| 148 | - 225 zxswing | ||
| 149 | - | ||
| 150 | - | ||
| 151 | - // Get Observable of List<Contributor> | ||
| 152 | - // Then from each contributor object in that List | ||
| 153 | - // emit stream of User Observables (by making retrofit call) --- 1/2 flatmap | ||
| 154 | - // combine into a single observable of User --- 2/2 flatmap | ||
| 155 | - // print out the name of user | ||
| 156 | - | ||
| 157 | - github.contributors("netflix", "rxjava") | ||
| 158 | - .lift(flattenList()) | ||
| 159 | - .flatMap(c -> gitHub.user(c.login)) | ||
| 160 | - .forEach(user -> println(user.name)); | ||
| 161 | - | ||
| 162 | - | ||
| 163 | - Observable.range(0, n) | ||
| 164 | - .flatMap({n -> doAsyncWorkThatReturnsObservable(n)}) | ||
| 165 | - .subscribe( | ||
| 166 | - { println(it); }, // onNext | ||
| 167 | - { println("Error: " + it.getMessage()); }, // onError | ||
| 168 | - { println("Sequence complete"); } // onCompleted | ||
| 169 | - ); | ||
| 170 | - | ||
| 171 | - Ben Christensen | ||
| 172 | - Shixong Zu | ||
| 173 | - | ||
| 174 | - | ||
| 175 | - // Get Observable of List<Contributor> | ||
| 176 | - // Then from each contributor object in that List | ||
| 177 | - // emit stream of User Observables (by making retrofit call) --- 1/2 flatmap | ||
| 178 | - // combine into a single observable of User --- 2/2 flatmap | ||
| 179 | - // filter only those users that have a name | ||
| 180 | - // print out the name of user | ||
| 181 | - | ||
| 182 | - github.contributors("netflix", "rxjava") | ||
| 183 | - .lift(flattenList()) | ||
| 184 | - .flatMap(c -> gitHub.user(c.login)) | ||
| 185 | - .filter(user -> user.name != null) | ||
| 186 | - .forEach(user -> println(user.name)); | ||
| 187 | - | ||
| 188 | - */ | ||
| 189 | - } | ||
| 135 | + } | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments