jlengrand/error-prone-support
1
0
Fork 0
mirror of https://github.com/jlengrand/error-prone-support.git synced 2026-03-10 08:11:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Flowable#blockingIterable Refaster template

Browse Source
This commit is contained in:
Rick Ossendrijver
2021-12-09 13:34:39 +01:00
committed by Pieter Dirk Soels
parent e6ea9fd37e
commit 05b6aa03df
3 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
error-prone-contrib/src/main/java/tech/picnic/errorprone/refastertemplates/RxJavaFlowableToReactorTemplates.java
View File

@@ -489,6 +489,19 @@ final class RxJavaFlowableToReactorTemplates {
// XXX: final Object blockingFirst(Object)
// XXX: final void blockingForEach(Consumer)
// XXX: final Iterable blockingIterable()
static final class FlowableBlockingIterable<T> {
@BeforeTemplate
Iterable<T> before(Flowable<T> flowable) {
return flowable.blockingIterable();
}
@AfterTemplate
Iterable<T> after(Flowable<T> flowable) {
return RxJava2Adapter.flowableToFlux(flowable).toIterable();
}
}
// XXX: final Iterable blockingIterable(int)
// XXX: final Object blockingLast()
// XXX: final Object blockingLast(Object)

4
error-prone-contrib/src/test/resources/tech/picnic/errorprone/bugpatterns/RxJavaFlowableToReactorTemplatesTestInput.java
View File

@@ -155,6 +155,10 @@ final class RxJavaFlowableToReactorTemplatesTest implements RefasterTemplateTest
return Flowable.just(1).blockingFirst();
}
Iterable<Integer> testFlowableBlockingIterable() {
return Flowable.just(1).blockingIterable();
}
Flowable<Integer> testFlowableConcatMap() {
return Flowable.just(1).concatMap(e -> Flowable::just);
}

4
error-prone-contrib/src/test/resources/tech/picnic/errorprone/bugpatterns/RxJavaFlowableToReactorTemplatesTestOutput.java
View File

@@ -190,6 +190,10 @@ final class RxJavaFlowableToReactorTemplatesTest implements RefasterTemplateTest
return RxJava2Adapter.flowableToFlux(Flowable.just(1)).blockFirst();
}
Iterable<Integer> testFlowableBlockingIterable() {
return RxJava2Adapter.flowableToFlux(Flowable.just(1)).toIterable();
}
Flowable<Integer> testFlowableConcatMap() {
return RxJava2Adapter.fluxToFlowable(
RxJava2Adapter.flowableToFlux(Flowable.just(1))