Movatterモバイル変換

Type Parameters:

T - the type of items expected to be emitted to theSubscriber

All Implemented Interfaces:

Observer<T>,Subscription

public classSerializedSubscriber<T>extendsSubscriber<T>

• Constructor Summary

  Constructors 

  Constructor and Description
  SerializedSubscriber(Subscriber<? superT> s)
  SerializedSubscriber(Subscriber<? superT> s, boolean shareSubscriptions) Constructor for wrapping and serializing a subscriber optionally sharing the same underlying subscription list.

• Method Summary

  All Methods Instance Methods Concrete Methods 

  Modifier and Type	Method and Description
  void	onCompleted() Notifies the Subscriber that theObservable has finished sending push-based notifications.
  void	onError(java.lang.Throwable e) Notifies the Subscriber that theObservable has experienced an error condition.
  void	onNext(T t) Provides the Subscriber with a new item to observe.

  • Methods inherited from class rx.Subscriber

    add,isUnsubscribed,onStart,request,setProducer,unsubscribe

  • Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• Constructor Detail

  • SerializedSubscriber

    public SerializedSubscriber(Subscriber<? superT> s)

  • SerializedSubscriber

    public SerializedSubscriber(Subscriber<? superT> s,                            boolean shareSubscriptions)

    Constructor for wrapping and serializing a subscriber optionally sharing the same underlying subscription list.

    Parameters:

    s - the subscriber to wrap and serialize

    shareSubscriptions - iftrue, the same subscription list is shared between this subscriber ands.

    Since:

    1.0.7

• Method Detail

  • onCompleted

    public void onCompleted()

    Notifies the Subscriber that theObservable has finished sending push-based notifications.

    TheObservable will not call this method if it callsonError(java.lang.Throwable).

  • onError

    public void onError(java.lang.Throwable e)

    Notifies the Subscriber that theObservable has experienced an error condition.

    If theObservable calls this method, it will not thereafter callonNext(T) oronCompleted().

    Parameters:

    e - the exception encountered by the Observable

  • onNext

    public void onNext(T t)

    Provides the Subscriber with a new item to observe.

    TheObservable may call this method 0 or more times.

    TheObservable will not call this method again after it calls eitheronCompleted() oronError(java.lang.Throwable).

    Parameters:

    t - the item emitted by the Observable