subscribe

public final Disposable subscribe(
			@Nullable Consumer<? super T> consumer,
			@Nullable Consumer<? super Throwable> errorConsumer,
			@Nullable Runnable completeConsumer,
			@Nullable Context initialContext)

• consumer：订阅的数据
• errorConsumer：处理错误的机制
• completeConsumer：订阅完后做响应的处理
• initialContext：订阅数据的量：默认为Long.MAX_VALUE

map和flatMap的区别

• map同步处理数据
• flatMap异步处理数据

takeUntil和takeWhile

takeWhile

takeUntil