Skip to content

Commit 96760af

Browse files
committed
Simplify 'buffer' signature to be the same as 'window'.
1 parent 8bb52a0 commit 96760af

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -345,9 +345,9 @@ trait Observable[+T]
345345
* An [[rx.lang.scala.Observable]] which produces connected non-overlapping buffers, which are emitted
346346
* when the current [[rx.lang.scala.Observable]] created with the function argument produces an object.
347347
*/
348-
def buffer[Closing](closings: () => Observable[_ <: Closing]) : Observable[Seq[T]] = {
349-
val f: Func0[_ <: rx.Observable[_ <: Closing]] = closings().asJavaObservable
350-
val jObs: rx.Observable[_ <: java.util.List[_]] = asJavaObservable.buffer[Closing](f)
348+
def buffer(closings: () => Observable[Any]) : Observable[Seq[T]] = {
349+
val f: Func0[_ <: rx.Observable[_ <: Any]] = closings().asJavaObservable
350+
val jObs: rx.Observable[_ <: java.util.List[_]] = asJavaObservable.buffer[Any](f)
351351
Observable.jObsOfListToScObsOfSeq(jObs.asInstanceOf[rx.Observable[_ <: java.util.List[T]]])
352352
}
353353
/**

0 commit comments

Comments
 (0)