InternalObservableUtils.ReplaySupplierBuffer

java.lang.Object

rx.internal.util.InternalObservableUtils.ReplaySupplierBuffer<T>

All Implemented Interfaces:: Callable<ConnectableObservable<T>>, Func0<ConnectableObservable<T>>, Function

Enclosing class:: InternalObservableUtils

static final class InternalObservableUtils.ReplaySupplierBuffer<T> extends Object implements Func0<ConnectableObservable<T>>

Field Summary

Fields

Modifier and Type

Field

Description

private final int

bufferSize

private final Observable<T>

source
Constructor Summary

Constructors

Modifier

Constructor

Description

private

ReplaySupplierBuffer(Observable<T> source, int bufferSize)
Method Summary

Modifier and Type

Method

Description

ConnectableObservable<T>

call()

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

Field Details
- source
  
  private final Observable<T> source
- bufferSize
  
  private final int bufferSize
Constructor Details
- ReplaySupplierBuffer
  
  private ReplaySupplierBuffer(Observable<T> source, int bufferSize)
Method Details
- call
  
  public ConnectableObservable<T> call()
  
  Specified by:
  
  call in interface Callable<T>
  
  Specified by:
  
  call in interface Func0<T>