Top Description Inners Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeMap<T, R>

extends Object
implements Observable.OnSubscribe<R>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the input value type
<R>
the return value type
Imports
rx.*, .Observable.OnSubscribe, rx.exceptions.*, rx.functions.Func1, rx.plugins.RxJavaHooks
Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
OnSubscribeMap.MapSubscriber<T, R>

Field Summary

Modifier and TypeField and Description
pack-priv final Observable<T>
source

pack-priv final Func1<? super T, ? extends R>
transformer

Constructor Summary

AccessConstructor and Description
public
OnSubscribeMap(Observable<T> source, Func1<? super T, ? extends R> transformer)

Method Summary

Modifier and TypeMethod and Description
public void
call(final Subscriber<? super R> o)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

sourceback to summary
pack-priv final Observable<T> source
transformerback to summary
pack-priv final Func1<? super T, ? extends R> transformer

Constructor Detail

OnSubscribeMapback to summary
public OnSubscribeMap(Observable<T> source, Func1<? super T, ? extends R> transformer)

Method Detail

callback to summary
public void call(final Subscriber<? super R> o)

Implements rx.functions.Action1.call.

Annotations
@Override
rx.internal.operators back to summary

pack-priv final Class OnSubscribeMap.MapSubscriber<T, R>

extends Subscriber<T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final Subscriber<? super R>
actual

pack-priv boolean
done

pack-priv final Func1<? super T, ? extends R>
mapper

Constructor Summary

AccessConstructor and Description
public
MapSubscriber(Subscriber<? super R> actual, Func1<? super T, ? extends R> mapper)

Method Summary

Modifier and TypeMethod and Description
public void
onCompleted()

Implements rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.
public void
onError(Throwable
the exception encountered by the Observable
e)

Implements rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.
public void
onNext(T
the item emitted by the Observable
t)

Implements rx.Observer.onNext.

Provides the Observer with a new item to observe.
public void
setProducer(Producer
producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from
p)

Overrides rx.Subscriber.setProducer.

If other subscriber is set (by calling constructor Subscriber(Subscriber) or Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber.
Inherited from rx.Subscriber:
addisUnsubscribedonStartrequestunsubscribe

Field Detail

actualback to summary
pack-priv final Subscriber<? super R> actual
doneback to summary
pack-priv boolean done
mapperback to summary
pack-priv final Func1<? super T, ? extends R> mapper

Constructor Detail

MapSubscriberback to summary
public MapSubscriber(Subscriber<? super R> actual, Func1<? super T, ? extends R> mapper)

Method Detail

onCompletedback to summary
public void onCompleted()

Implements rx.Observer.onCompleted.

Doc from rx.Observer.onCompleted.

Notifies the Observer that the Observable has finished sending push-based notifications.

The Observable will not call this method if it calls onError.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements rx.Observer.onError.

Doc from rx.Observer.onError.

Notifies the Observer that the Observable has experienced an error condition.

If the Observable calls this method, it will not thereafter call onNext or onCompleted.

Parameters
e:Throwable

the exception encountered by the Observable

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements rx.Observer.onNext.

Doc from rx.Observer.onNext.

Provides the Observer with a new item to observe.

The Observable may call this method 0 or more times.

The Observable will not call this method again after it calls either onCompleted or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override
setProducerback to summary
public void setProducer(Producer p)

Overrides rx.Subscriber.setProducer.

Doc from rx.Subscriber.setProducer.

If other subscriber is set (by calling constructor Subscriber(Subscriber) or Subscriber(Subscriber, boolean)) then this method calls setProducer on the other subscriber. If the other subscriber is not set and no requests have been made to this subscriber then p.request(Long.MAX_VALUE) is called. If the other subscriber is not set and some requests have been made to this subscriber then p.request(n) is called where n is the accumulated requests to this subscriber.

Parameters
p:Producer

producer to be used by this subscriber or the other subscriber (or recursively its other subscriber) to make requests from

Annotations
@Override