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

Functions.toMapKeySelector介绍

暂无

代码示例

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns a Single that emits a single HashMap containing all items emitted by the
 * finite source ObservableSource, mapped by the keys returned by a specified
 * {@code keySelector} function.
 * <p>
 * <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/toMap.2.png" alt="">
 * <p>
 * If more than one source item maps to the same key, the HashMap will contain the latest of those items.
 * <p>
 * Note that this operator requires the upstream to signal {@code onComplete} for the accumulated map to
 * be emitted. Sources that are infinite and never complete will never emit anything through this
 * operator and an infinite source may lead to a fatal {@code OutOfMemoryError}.
 * <dl>
 *  <dt><b>Scheduler:</b></dt>
 *  <dd>{@code toMap} does not operate by default on a particular {@link Scheduler}.</dd>
 * </dl>
 *
 * @param <K> the key type of the Map
 * @param keySelector
 *            the function that extracts the key from a source item to be used in the HashMap
 * @return a Single that emits a single item: a HashMap containing the mapped items from the source
 *         ObservableSource
 * @see <a href="http://reactivex.io/documentation/operators/to.html">ReactiveX operators documentation: To</a>
 */
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final <K> Single<Map<K, T>> toMap(final Function<? super T, ? extends K> keySelector) {
  ObjectHelper.requireNonNull(keySelector, "keySelector is null");
  return collect(HashMapSupplier.<K, T>asCallable(), Functions.toMapKeySelector(keySelector));
}

代码示例来源：origin: ReactiveX/RxJava

public final <K> Single<Map<K, T>> toMap(final Function<? super T, ? extends K> keySelector) {
  ObjectHelper.requireNonNull(keySelector, "keySelector is null");
  return collect(HashMapSupplier.<K, T>asCallable(), Functions.toMapKeySelector(keySelector));

代码示例来源：origin: redisson/redisson

/**
 * Returns a Single that emits a single HashMap containing all items emitted by the
 * finite source ObservableSource, mapped by the keys returned by a specified
 * {@code keySelector} function.
 * <p>
 * <img width="640" height="305" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/toMap.2.png" alt="">
 * <p>
 * If more than one source item maps to the same key, the HashMap will contain the latest of those items.
 * <p>
 * Note that this operator requires the upstream to signal {@code onComplete} for the accumulated map to
 * be emitted. Sources that are infinite and never complete will never emit anything through this
 * operator and an infinite source may lead to a fatal {@code OutOfMemoryError}.
 * <dl>
 *  <dt><b>Scheduler:</b></dt>
 *  <dd>{@code toMap} does not operate by default on a particular {@link Scheduler}.</dd>
 * </dl>
 *
 * @param <K> the key type of the Map
 * @param keySelector
 *            the function that extracts the key from a source item to be used in the HashMap
 * @return a Single that emits a single item: a HashMap containing the mapped items from the source
 *         ObservableSource
 * @see <a href="http://reactivex.io/documentation/operators/to.html">ReactiveX operators documentation: To</a>
 */
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final <K> Single<Map<K, T>> toMap(final Function<? super T, ? extends K> keySelector) {
  ObjectHelper.requireNonNull(keySelector, "keySelector is null");
  return collect(HashMapSupplier.<K, T>asCallable(), Functions.toMapKeySelector(keySelector));
}

代码示例来源：origin: redisson/redisson

public final <K> Single<Map<K, T>> toMap(final Function<? super T, ? extends K> keySelector) {
  ObjectHelper.requireNonNull(keySelector, "keySelector is null");
  return collect(HashMapSupplier.<K, T>asCallable(), Functions.toMapKeySelector(keySelector));