View Javadoc
1   package com.github.davidmoten.rx.util;
2   
3   import rx.Observable;
4   
5   public enum BackpressureStrategy {
6       /**
7        * Corresponds to {@link Observable#onBackpressureBuffer}.
8        */
9       BUFFER,
10  
11      /**
12       * Corresponds to {@link Observable#onBackpressureDrop}.
13       */
14      DROP,
15  
16      /**
17       * Corresponds to {@link Observable#onBackpressureLatest}.
18       */
19      LATEST;
20  }