Skip to content

Commit

Permalink
Polish
Browse files Browse the repository at this point in the history
  • Loading branch information
sdeleuze committed Nov 3, 2016
1 parent 1596e8f commit 9acd9eb
Showing 1 changed file with 22 additions and 22 deletions.
44 changes: 22 additions & 22 deletions src/test/java/io/pivotal/literx/Part09Conversion.java
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,28 @@ public class Part09Conversion {

ReactiveRepository<User> repository = new ReactiveUserRepository();

//========================================================================================

@Test
public void adaptToFlowable() {
Flux<User> flux = repository.findAll();
Flowable<User> observable = fromFluxToFlowable(flux);
StepVerifier.create(fromFlowableToFlux(observable))
.expectNext(User.SKYLER, User.JESSE, User.WALTER, User.SAUL)
.expectComplete()
.verify();
}

// TODO Convert Flux to RxJava Flowable
Flowable<User> fromFluxToFlowable(Flux<User> flux) {
return null;
}

// TODO Convert RxJava Flowable to Flux
Flux<User> fromFlowableToFlux(Flowable<User> flowable) {
return null;
}

//========================================================================================

@Test
Expand Down Expand Up @@ -92,28 +114,6 @@ Mono<User> fromSingleToMono(Single<User> single) {
return null;
}

//========================================================================================

@Test
public void adaptToFlowable() {
Flux<User> flux = repository.findAll();
Observable<User> observable = fromFluxToObservable(flux);
StepVerifier.create(fromObservableToFlux(observable))
.expectNext(User.SKYLER, User.JESSE, User.WALTER, User.SAUL)
.expectComplete()
.verify();
}

// TODO Convert Flux to RxJava Flowable
Flowable<User> fromFluxToFlowable(Flux<User> flux) {
return null;
}

// TODO Convert RxJava Flowable to Flux
Flux<User> fromFlowableToFlux(Flowable<User> flowable) {
return null;
}

//========================================================================================

@Test
Expand Down

0 comments on commit 9acd9eb

Please sign in to comment.