OperatorReplay

rx.internal.operators

Class OperatorReplay

java.lang.Object
- rx.internal.operators.OperatorReplay

```
public final class OperatorReplay
extends Object
```
Replay with limited buffer and/or time constraints.

See Also:

MSDN: Observable.Replay overloads

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
`static class`	`OperatorReplay.SubjectWrapper<T>` A subject that wraps another subject.

Method Summary

Methods

Modifier and Type	Method and Description
`static <T> Subject<T,T>`	`createScheduledSubject(Subject<T,T> subject, Scheduler scheduler)` Creates a subject whose client observers will observe events propagated through the given wrapped subject.
`static <T> Observable.OnSubscribe<T>`	`subscriberOf(Observable<T> target)` Return an OnSubscribeFunc which delegates the subscription to the given observable.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - createScheduledSubject
```
public static <T> Subject<T,T> createScheduledSubject(Subject<T,T> subject,
                                                      Scheduler scheduler)
```
    Creates a subject whose client observers will observe events propagated through the given wrapped subject.
    
    Type Parameters:
    
    T - the element type
    
    Parameters:
    
    subject - the subject to wrap
    
    scheduler - the target scheduler
    
    Returns:
    
    the created subject
  - subscriberOf
```
public static <T> Observable.OnSubscribe<T> subscriberOf(Observable<T> target)
```
    Return an OnSubscribeFunc which delegates the subscription to the given observable.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    target - the target observable
    
    Returns:
    
    the function that delegates the subscription to the target