本文整理了Java中io.reactivex.subjects.Subject.ofType()方法的一些代码示例，展示了Subject.ofType()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Subject.ofType()方法的具体详情如下：
包路径：io.reactivex.subjects.Subject
类名称：Subject
方法名：ofType

Subject.ofType介绍

暂无

代码示例

代码示例来源：origin: leftcoding/GankLy

/**
 * 根据传递的 eventType 类型返回特定类型(eventType)的 被观察者
 *
 * @param eventType 事件类型
 * @param <T>
 * @return
 */
public <T> Observable<T> toObservable(Class<T> eventType) {
  return bus.ofType(eventType);
}

代码示例来源：origin: leftcoding/GankLy

/**
 * 根据传递的 eventType 类型返回特定类型(eventType)的 被观察者
 */
public <T> Observable<T> toObservable(Class<T> eventType) {
  return mBus.ofType(eventType);
}

代码示例来源：origin: burgessjp/GanHuoIO

public <T> Observable<T> toObservable(Class<T> eventType) {
    return _bus.ofType(eventType);
  }
}

代码示例来源：origin: CoderLengary/WanAndroid

public <T>Observable<T> tObservable(Class<T> classType){
  return subject.ofType(classType);
}

代码示例来源：origin: adgvcxz/Dribbble-MVVM

public <T> Observable<T> toObservable(Class<T> eventType) {
    return bus.ofType(eventType);
  }
}

代码示例来源：origin: leftcoding/GankLy

/**
 * 根据传递的 eventType 类型返回特定类型(eventType)的 被观察者
 */
public <T> Observable<T> toObservableSticky(final Class<T> eventType) {
  synchronized (mStickyEventMap) {
    Observable<T> observable = mBus.ofType(eventType);
    final Object event = mStickyEventMap.get(eventType);
    if (event != null) {
      return observable.mergeWith(Observable.create(new ObservableOnSubscribe<T>() {
        @Override
        public void subscribe(ObservableEmitter<T> subscriber) throws Exception {
          subscriber.onNext(eventType.cast(event));
        }
      }));
    } else {
      return observable;
    }
  }
}

代码示例来源：origin: leftcoding/GankLy

/**
 * 根据传递的code和 eventType 类型返回特定类型(eventType)的 被观察者
 *
 * @param code      事件code
 * @param eventType 事件类型
 * @param <T>
 * @return
 */
public <T> Observable<T> toObservable(final int code, final Class<T> eventType) {
  return bus.ofType(Message.class)
      .filter(message -> message.getCode() == code && eventType.isInstance(message.getObject()))
      .map(message -> message.getObject())
      .cast(eventType);
}